Waiters

Index > Kinesis > Waiters

Auto-generated documentation for Kinesis type annotations stubs module types-aiobotocore-kinesis.

StreamExistsWaiter

Type annotations and code completion for session.create_client("kinesis").get_waiter("stream_exists"). boto3 documentation

# StreamExistsWaiter usage example

from aiobotocore.session import Session

from types_aiobotocore_kinesis.waiter import StreamExistsWaiter

session = get_session()
async with session.create_client("kinesis") as client:  # (1)
    waiter: StreamExistsWaiter = client.get_waiter("stream_exists")  # (2)
    await waiter.wait()

1. client: KinesisClient
2. waiter: StreamExistsWaiter

wait

Type annotations and code completion for StreamExistsWaiter.wait method.

# wait method definition

await def wait(
    self,
    *,
    StreamName: str = ...,
    Limit: int = ...,
    ExclusiveStartShardId: str = ...,
    StreamARN: str = ...,
    WaiterConfig: WaiterConfigTypeDef = ...,  # (1)
) -> None:
    ...

1. See WaiterConfigTypeDef

# wait method usage example with argument unpacking

kwargs: DescribeStreamInputStreamExistsWaitTypeDef = {  # (1)
    "StreamName": ...,
}

parent.wait(**kwargs)

1. See DescribeStreamInputStreamExistsWaitTypeDef

StreamNotExistsWaiter

Type annotations and code completion for session.create_client("kinesis").get_waiter("stream_not_exists"). boto3 documentation

# StreamNotExistsWaiter usage example

from aiobotocore.session import Session

from types_aiobotocore_kinesis.waiter import StreamNotExistsWaiter

session = get_session()
async with session.create_client("kinesis") as client:  # (1)
    waiter: StreamNotExistsWaiter = client.get_waiter("stream_not_exists")  # (2)
    await waiter.wait()

1. client: KinesisClient
2. waiter: StreamNotExistsWaiter

wait

Type annotations and code completion for StreamNotExistsWaiter.wait method.

# wait method definition

await def wait(
    self,
    *,
    StreamName: str = ...,
    Limit: int = ...,
    ExclusiveStartShardId: str = ...,
    StreamARN: str = ...,
    WaiterConfig: WaiterConfigTypeDef = ...,  # (1)
) -> None:
    ...

1. See WaiterConfigTypeDef

# wait method usage example with argument unpacking

kwargs: DescribeStreamInputStreamNotExistsWaitTypeDef = {  # (1)
    "StreamName": ...,
}

parent.wait(**kwargs)

1. See DescribeStreamInputStreamNotExistsWaitTypeDef