Skip to content

Commit 304d491

Browse files
committed
remove unused code
1 parent 77d48a3 commit 304d491

File tree

1 file changed

+0
-23
lines changed

1 file changed

+0
-23
lines changed

ydb/_topic_writer/topic_writer_asyncio.py

Lines changed: 0 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -429,29 +429,6 @@ async def create(
429429
await writer._start(stream, init_request)
430430
return writer
431431

432-
@staticmethod
433-
async def _create_stream_from_async(
434-
driver: ydb.aio.Driver,
435-
init_request: StreamWriteMessage.InitRequest,
436-
token_getter: TokenGetterFuncType,
437-
) -> "WriterAsyncIOStream":
438-
return GrpcWrapperAsyncIO(StreamWriteMessage.FromServer.from_proto)
439-
440-
@staticmethod
441-
async def _create_from_sync(
442-
driver: ydb.Driver,
443-
init_request: StreamWriteMessage.InitRequest,
444-
token_getter: TokenGetterFuncType,
445-
) -> "WriterAsyncIOStream":
446-
stream = GrpcWrapperAsyncIO(StreamWriteMessage.FromServer.from_proto)
447-
await stream.start(
448-
driver, _apis.TopicService.Stub, _apis.TopicService.StreamWrite
449-
)
450-
451-
writer = WriterAsyncIOStream(token_getter)
452-
await writer._start(stream, init_request)
453-
return writer
454-
455432
async def receive(self) -> StreamWriteMessage.WriteResponse:
456433
while True:
457434
item = await self._stream.receive()

0 commit comments

Comments
 (0)