[Fact]
public void Read_ObservableReadsFromUnderlyingStream()
{
// Don't need to mock stream, and it's easier to use MemoryStream.
Stream stream = new MemoryStream();
var scheduler = new TestScheduler();
var mockObserver = new Mock<IObserver<byte[]>>();
var bytes = new byte[] { 1, 2, 3, 4, 5 };
var networkConnection = new NetworkConnection(stream, (IScheduler)scheduler);
// This does violate LoD but it gives us a lot more flexibility