OQueueImplementation will need to be extended to support sharing ring buffers between observers. This will
require a number of changes:
- The
ObservationRingBuffer type will need to be generalized to handle multiple observers.
Make sure to search for let head_id = 0 to find the hard coded assumption that there is only
one strong observer per ring buffer.
- Some form of reference counting will be needed to track if a ring buffer is still in use by
come observer.
- If query push down is supported, the queries will need to be split into a function to collect
the union of all needed data, and another to extract the data for each specific observer.
OQueueImplementationwill need to be extended to support sharing ring buffers between observers. This willrequire a number of changes:
ObservationRingBuffertype will need to be generalized to handle multiple observers.Make sure to search for
let head_id = 0to find the hard coded assumption that there is onlyone strong observer per ring buffer.
come observer.
the union of all needed data, and another to extract the data for each specific observer.