Open wassim-k opened 1 year ago
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(); }
The following code:
Throws a null reference exception in the folliwng line: