Calling Connect() on a ConnectableStreamable without subscribers throw System.NullReferenceException

[wassim-k]

The following code:

var stream = Observable.Empty<int>()
    .ToAtemporalStreamable()
    .Publish();

stream.Connect();

Throws a null reference exception in the folliwng line:

public void OnNext(StreamMessage<TKey, TPayload> batch)
{
    this.on(batch); // <===== on is null here
    batch.Free();
}