pub(self) fn new(body: hyper::Body) -> Self {
        Self {
            records: RecordIoConnection::new(body),
        }
    }
/// Constructs a new event stream from the response body of the scheduler API.
///
/// Note, the event stream should be created by `Client::connect` which returns a client and an
/// event stream.
Constructs a new event stream from the response body of the scheduler API.
Note, the event stream should be created by `Client::connect` which returns a client and an
event stream.
Constructs a new event stream from the response body of the scheduler API . Note the event stream should be created by ` Client :: connect ` which returns a client and an event stream .
pub(self) fn new(body: hyper::Body) -> Self {
        Self {
            records: RecordIoConnection::new(body),
        }
    }
pub ( self ) fn new ( body : hyper :: Body ) -> Self { Self { records : RecordIoConnection :: new ( body ) , } }
Constructs a new event stream from the response body of the scheduler API.
Constructs a new event stream from the response body of the scheduler API .
body
hyper::Body
body
hyper::Body