Lines Matching refs:Command
17 Command, FuturePayload, StreamReadPayload, StreamReadyPayload, StreamWritePayload,
33 pub commands: Vec<(Scope, Command)>,
126 deferred: Vec<(Scope, Command)>,
324 commands: &mut Vec<(Scope, Command)>, in generate() argument
440 commands.push((caller, Command::SyncReadyCall)); in generate()
444 commands.push((caller, Command::AsyncReadyCall)); in generate()
451 commands.push((caller, Command::AsyncPendingImportCall(id))); in generate()
466 commands.push((callee, Command::AsyncPendingExportComplete(id))); in generate()
468 .push((caller, Command::AsyncPendingImportAssertReady(id))); in generate()
470 commands.push((caller, Command::AsyncPendingImportCancel(id))); in generate()
472 .push((callee, Command::AsyncPendingExportAssertCancelled(id))); in generate()
485 commands.push((scope, Command::FutureNew(id))); in generate()
517 commands.push((caller, Command::FutureTake(id))); in generate()
521 commands.push((*scope, Command::FutureGive(id))); in generate()
554 Command::FutureReadReady(FuturePayload { future: id, item }), in generate()
557 commands.push((write_scope, Command::FutureWriteAssertComplete(id))); in generate()
573 commands.push((scope, Command::FutureReadPending(id))); in generate()
588 commands.push((scope, Command::FutureWriteDropped(id))); in generate()
594 commands.push((scope, Command::FutureWriteReady(payload))); in generate()
596 commands.push((read_scope, Command::FutureReadAssertComplete(payload))); in generate()
604 commands.push((scope, Command::FutureWritePending(payload))); in generate()
616 commands.push((scope, Command::FutureCancelWrite(id))); in generate()
620 commands.push((scope, Command::FutureWriteAssertDropped(id))); in generate()
634 commands.push((scope, Command::FutureCancelRead(id))); in generate()
646 commands.push((scope, Command::FutureDropReadable(id))); in generate()
666 commands.push((scope, Command::FutureWriteDropped(id))); in generate()
674 commands.push((scope, Command::StreamNew(id))); in generate()
703 commands.push((caller, Command::StreamTake(id))); in generate()
707 commands.push((*scope, Command::StreamGive(id))); in generate()
738 commands.push((scope, Command::StreamDropReadable(id))); in generate()
749 commands.push((scope, Command::StreamDropWritable(id))); in generate()
772 Command::StreamReadDropped(StreamReadPayload { stream: id, count }), in generate()
797 Command::StreamReadPending(StreamReadPayload { stream: id, count }), in generate()
802 Command::StreamWriteAssertComplete(StreamReadPayload { in generate()
815 Command::StreamReadReady(StreamReadyPayload { in generate()
829 Command::StreamReadReady(StreamReadyPayload { in generate()
838 Command::StreamWriteAssertComplete(StreamReadPayload { in generate()
853 Command::StreamReadPending(StreamReadPayload { stream: id, count }), in generate()
875 Command::StreamWriteDropped(StreamWritePayload { in generate()
898 Command::StreamWriteReady(StreamReadyPayload { in generate()
917 Command::StreamWritePending(StreamWritePayload { in generate()
926 Command::StreamReadAssertComplete(StreamWritePayload { in generate()
939 Command::StreamWriteReady(StreamReadyPayload { in generate()
949 Command::StreamReadAssertComplete(StreamWritePayload { in generate()
965 Command::StreamWritePending(StreamWritePayload { in generate()
982 commands.push((scope, Command::StreamCancelRead(id))); in generate()
985 commands.push((scope, Command::StreamReadAssertDropped(id))); in generate()
998 commands.push((scope, Command::StreamCancelWrite(id))); in generate()
1003 Command::StreamWriteAssertDropped(StreamReadPayload { in generate()