docs: @PublicEvolving
  	public <R> BroadcastConnectedStream<T, R> connect(BroadcastStream<R> broadcastStream) {
  		return new BroadcastConnectedStream<>(
  				environment,
  				this,
  				Preconditions.checkNotNull(broadcastStream),
  				broadcastStream.getBroadcastStateDescriptor());
  	}