pub async fn wait_for_data<C: TfCodec>( socket: &mut Framed<Transport, C>, ) -> Result<BytesMut, ClientError>