Rx relies on operator composition instead of overloads. To reduce the batch size sent upstream, you can include the rebatchRequests operator in the stream.

source.rebatchRequests(1).subscribe(...)