open

fun open(capacity: Int): SharedDataStream