Implement the durable streams API as implemented in other Transact SDKs https://github.com/dbos-inc/dbos-transact-py/pull/420