ListenableSubscription constructor Null safety

ListenableSubscription(ValueListenable endOfPipe)

Implementation

ListenableSubscription(this.endOfPipe);