Lines Matching refs:HostStreamConsumerStateKind

614                 state.kind = HostStreamConsumerStateKind::Consuming(payload.op_count);  in future_or_stream_cmd()
619                     HostStreamConsumerStateKind::Consumed(_),  in future_or_stream_cmd()
627                     HostStreamConsumerStateKind::Consumed(last_read) => {  in future_or_stream_cmd()
632                         state.kind = HostStreamConsumerStateKind::Idle;  in future_or_stream_cmd()
664                 assert!(matches!(state.kind, HostStreamConsumerStateKind::Idle));  in future_or_stream_cmd()
665                 state.kind = HostStreamConsumerStateKind::Consuming(payload.count);  in future_or_stream_cmd()
690                 assert!(matches!(state.kind, HostStreamConsumerStateKind::Idle));  in future_or_stream_cmd()
707                 HostStreamConsumerStateKind::Consuming(_)  in future_or_stream_cmd()
709             state.kind = HostStreamConsumerStateKind::Idle;  in future_or_stream_cmd()
718                 HostStreamConsumerStateKind::Consumed(last_read) => {  in future_or_stream_cmd()
720                     state.kind = HostStreamConsumerStateKind::Idle;  in future_or_stream_cmd()
768                     HostStreamConsumerStateKind::Consuming(_),  in future_or_stream_cmd()
812                     kind: HostStreamConsumerStateKind::Idle,  in ensure_stream_reading()
943     kind: HostStreamConsumerStateKind,
947 enum HostStreamConsumerStateKind {  enum
980             HostStreamConsumerStateKind::Idle | HostStreamConsumerStateKind::Consumed(_) => {  in poll_consume()
991             HostStreamConsumerStateKind::Consuming(amt) => {  in poll_consume()
1002                     state.kind = HostStreamConsumerStateKind::Consumed(Vec::new());  in poll_consume()
1017                 state.kind = HostStreamConsumerStateKind::Consumed(dst);  in poll_consume()