Streaming management code for Observatories