Stream (reddit_api_async.Reddit_api

val stream : 
  (module Core.Hashtbl.Key_plain with type t = 'id) ->
  Connection.t ->
  get_listing:
    (before:'id option ->
      limit:int ->
      'thing list Reddit_api_kernel.Endpoint.t) ->
  get_before_parameter:('thing -> 'id) ->
  ('thing, Reddit_api_kernel.Endpoint.Error.t Connection.Error.t) Core.Result.t
    Async.Pipe.Reader.t