Skip to content

Commit

Permalink
added next to cross_sync
Browse files Browse the repository at this point in the history
  • Loading branch information
daniel-sanche committed Aug 30, 2024
1 parent ebf126a commit 792abd9
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion google/cloud/bigtable/data/_sync/cross_sync/cross_sync.py
Original file line number Diff line number Diff line change
Expand Up @@ -105,6 +105,10 @@ class CrossSync(metaclass=MappingMeta):
PytestFixture.decorator
) # decorate test methods to run with pytest fixture

@classmethod
def next(cls, iterable):
return iterable.__anext__()

@classmethod
def Mock(cls, *args, **kwargs):
"""
Expand Down Expand Up @@ -230,7 +234,7 @@ def verify_async_event_loop() -> None:
asyncio.get_running_loop()

@staticmethod
def rm_aio(statement: Any) -> Any:
def rm_aio(statement: T) -> T:
"""
Used to annotate regions of the code containing async keywords to strip
Expand All @@ -247,6 +251,7 @@ class _Sync_Impl(metaclass=MappingMeta):
is_async = False

sleep = time.sleep
next = next
retry_target = retries.retry_target
retry_target_stream = retries.retry_target_stream
Retry = retries.Retry
Expand Down

0 comments on commit 792abd9

Please sign in to comment.