Searched defs:StreamingBase (Results 1 – 1 of 1) sorted by relevance
512 struct StreamingBase { struct518 impl StreamingBase { argument519 fn new(close_f: Option<BatchFuture>) -> StreamingBase { in new()