Skip to content

Commit 05148f2

Browse files
committed
Make futures make sense independently of streams
1 parent 52619a0 commit 05148f2

File tree

6 files changed

+710
-430
lines changed

6 files changed

+710
-430
lines changed

design/mvp/Async.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -610,7 +610,7 @@ Despite the above, the following scenarios do behave deterministically:
610610
that was blocked before starting due to backpressure, cancellation completes
611611
deterministically and immediately.
612612
* When both ends of a stream or future are owned by wasm components, the
613-
behavior of all read, write, cancel and close operations is deterministic
613+
behavior of all read, write, cancel and drop operations is deterministic
614614
(modulo any nondeterminitic execution that determines the ordering in which
615615
the operations are performed).
616616

design/mvp/Binary.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -302,15 +302,15 @@ canon ::= 0x00 0x00 f:<core:funcidx> opts:<opts> ft:<typeidx> => (canon lift
302302
| 0x10 t:<typeidx> opts:<opts> => (canon stream.write t opts (core func)) 🔀
303303
| 0x11 t:<typeidx> async?:<async?> => (canon stream.cancel-read async? (core func)) 🔀
304304
| 0x12 t:<typeidx> async?:<async?> => (canon stream.cancel-write async? (core func)) 🔀
305-
| 0x13 t:<typeidx> => (canon stream.close-readable t (core func)) 🔀
306-
| 0x14 t:<typeidx> => (canon stream.close-writable t (core func)) 🔀
305+
| 0x13 t:<typeidx> => (canon stream.drop-readable t (core func)) 🔀
306+
| 0x14 t:<typeidx> => (canon stream.drop-writable t (core func)) 🔀
307307
| 0x15 t:<typeidx> => (canon future.new t (core func)) 🔀
308308
| 0x16 t:<typeidx> opts:<opts> => (canon future.read t opts (core func)) 🔀
309309
| 0x17 t:<typeidx> opts:<opts> => (canon future.write t opts (core func)) 🔀
310310
| 0x18 t:<typeidx> async?:<async?> => (canon future.cancel-read async? (core func)) 🔀
311311
| 0x19 t:<typeidx> async?:<async?> => (canon future.cancel-write async? (core func)) 🔀
312-
| 0x1a t:<typeidx> => (canon future.close-readable t (core func)) 🔀
313-
| 0x1b t:<typeidx> => (canon future.close-writable t (core func)) 🔀
312+
| 0x1a t:<typeidx> => (canon future.drop-readable t (core func)) 🔀
313+
| 0x1b t:<typeidx> => (canon future.drop-writable t (core func)) 🔀
314314
| 0x1c opts:<opts> => (canon error-context.new opts (core func)) 📝
315315
| 0x1d opts:<opts> => (canon error-context.debug-message opts (core func)) 📝
316316
| 0x1e => (canon error-context.drop (core func)) 📝

0 commit comments

Comments
 (0)