Refactoring: reduce code duplication in UsingLinq_Databus_Streaming and UsingLinq_Databus_NonStreaming