Observable < Integer > function ( Iterable < Integer > arg0 ) { return Observable . create ( ( Subscriber < ? super Integer > loc0 ) -> { for ( Integer loc1 : arg0 ) { if ( loc0 . isUnsubscribed ( ) ) { return ; } loc0 . onNext ( loc1 ) ; } loc0 . onCompleted ( ) ; } ) ; }
this does not implement `` reactive pull '' so will `` firehose '' all data at the subscriber . concode_field_sep PlaceHolder placeHolder concode_field_sep void main concode_elem_sep Observable<Integer> getData