VimPlug/typeshed
1
0
Fork 0
mirror of https://github.com/davidhalter/typeshed.git synced 2026-05-24 17:28:40 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add default values for third-party stubs beginning with 'P' (#9957)

Browse Source
This commit is contained in:
Alex Waygood
2023-03-27 18:58:53 +01:00
committed by GitHub
parent 20f9b3685d
commit 6fd7e36e80
248 changed files with 2181 additions and 2133 deletions
Download Patch File Download Diff File Expand all files Collapse all files
stubs/pika/pika/adapters/asyncio_connection.pyi
+9 -9
View File
@@ -13,16 +13,16 @@ LOGGER: Logger
class AsyncioConnection(BaseConnection):
def __init__(
self,
parameters: Parameters | None = ...,
on_open_callback: Callable[[Self], object] | None = ...,
on_open_error_callback: Callable[[Self, BaseException], object] | None = ...,
on_close_callback: Callable[[Self, BaseException], object] | None = ...,
custom_ioloop: AbstractEventLoop | None = ...,
internal_connection_workflow: bool = ...,
parameters: Parameters | None = None,
on_open_callback: Callable[[Self], object] | None = None,
on_open_error_callback: Callable[[Self, BaseException], object] | None = None,
on_close_callback: Callable[[Self, BaseException], object] | None = None,
custom_ioloop: AbstractEventLoop | None = None,
internal_connection_workflow: bool = True,
) -> None: ...
@classmethod
def create_connection(
cls, connection_configs, on_done, custom_ioloop: AbstractEventLoop | None = ..., workflow: Incomplete | None = ...
cls, connection_configs, on_done, custom_ioloop: AbstractEventLoop | None = None, workflow: Incomplete | None = None
): ...
class _AsyncioIOServicesAdapter(
@@ -31,14 +31,14 @@ class _AsyncioIOServicesAdapter(
nbio_interface.AbstractIOServices,
nbio_interface.AbstractFileDescriptorServices,
):
def __init__(self, loop: Incomplete | None = ...) -> None: ...
def __init__(self, loop: Incomplete | None = None) -> None: ...
def get_native_ioloop(self): ...
def close(self) -> None: ...
def run(self) -> None: ...
def stop(self) -> None: ...
def add_callback_threadsafe(self, callback) -> None: ...
def call_later(self, delay, callback): ...
def getaddrinfo(self, host, port, on_done, family: int = ..., socktype: int = ..., proto: int = ..., flags: int = ...): ...
def getaddrinfo(self, host, port, on_done, family: int = 0, socktype: int = 0, proto: int = 0, flags: int = 0): ...
def set_reader(self, fd, on_readable) -> None: ...
def remove_reader(self, fd): ...
def set_writer(self, fd, on_writable) -> None: ...
stubs/pika/pika/adapters/base_connection.pyi
+1 -1
View File
@@ -21,7 +21,7 @@ class BaseConnection(Connection, metaclass=abc.ABCMeta):
@classmethod
@abc.abstractmethod
def create_connection(
cls, connection_configs, on_done, custom_ioloop: Incomplete | None = ..., workflow: Incomplete | None = ...
cls, connection_configs, on_done, custom_ioloop: Incomplete | None = None, workflow: Incomplete | None = None
): ...
@property
def ioloop(self): ...
stubs/pika/pika/adapters/blocking_connection.pyi
+55 -42
View File
@@ -12,7 +12,7 @@ from ..spec import BasicProperties
LOGGER: Incomplete
class _CallbackResult:
def __init__(self, value_class: Incomplete | None = ...) -> None: ...
def __init__(self, value_class: Incomplete | None = None) -> None: ...
def reset(self) -> None: ...
def __bool__(self) -> bool: ...
__nonzero__: Incomplete
@@ -55,7 +55,7 @@ class BlockingConnection:
class _OnChannelOpenedArgs(NamedTuple):
channel: Incomplete
def __init__(
self, parameters: Parameters | Sequence[Parameters] | None = ..., _impl_class: Incomplete | None = ...
self, parameters: Parameters | Sequence[Parameters] | None = None, _impl_class: Incomplete | None = None
) -> None: ...
def __enter__(self) -> Self: ...
def __exit__(
@@ -67,10 +67,10 @@ class BlockingConnection:
def add_callback_threadsafe(self, callback) -> None: ...
def remove_timeout(self, timeout_id) -> None: ...
def update_secret(self, new_secret, reason) -> None: ...
def close(self, reply_code: int = ..., reply_text: str = ...) -> None: ...
def process_data_events(self, time_limit: int = ...): ...
def close(self, reply_code: int = 200, reply_text: str = "Normal shutdown") -> None: ...
def process_data_events(self, time_limit: int = 0): ...
def sleep(self, duration: float) -> None: ...
def channel(self, channel_number: int | None = ...) -> BlockingChannel: ...
def channel(self, channel_number: int | None = None) -> BlockingChannel: ...
@property
def is_closed(self) -> bool: ...
@property
@@ -128,7 +128,11 @@ class _ConsumerInfo:
alternate_event_sink: Incomplete
state: Incomplete
def __init__(
self, consumer_tag, auto_ack, on_message_callback: Incomplete | None = ..., alternate_event_sink: Incomplete | None = ...
self,
consumer_tag,
auto_ack,
on_message_callback: Incomplete | None = None,
alternate_event_sink: Incomplete | None = None,
) -> None: ...
@property
def setting_up(self): ...
@@ -176,7 +180,7 @@ class BlockingChannel:
def is_open(self): ...
@property
def consumer_tags(self): ...
def close(self, reply_code: int = ..., reply_text: str = ...): ...
def close(self, reply_code: int = 0, reply_text: str = "Normal shutdown"): ...
def flow(self, active): ...
def add_on_cancel_callback(self, callback) -> None: ...
def add_on_return_callback(self, callback): ...
@@ -184,67 +188,76 @@ class BlockingChannel:
self,
queue,
on_message_callback,
auto_ack: bool = ...,
exclusive: bool = ...,
consumer_tag: Incomplete | None = ...,
arguments: Incomplete | None = ...,
auto_ack: bool = False,
exclusive: bool = False,
consumer_tag: Incomplete | None = None,
arguments: Incomplete | None = None,
): ...
def basic_cancel(self, consumer_tag): ...
def start_consuming(self) -> None: ...
def stop_consuming(self, consumer_tag: Incomplete | None = ...) -> None: ...
def stop_consuming(self, consumer_tag: Incomplete | None = None) -> None: ...
def consume(
self,
queue,
auto_ack: bool = ...,
exclusive: bool = ...,
arguments: Incomplete | None = ...,
inactivity_timeout: Incomplete | None = ...,
auto_ack: bool = False,
exclusive: bool = False,
arguments: Incomplete | None = None,
inactivity_timeout: Incomplete | None = None,
) -> Generator[Incomplete, None, None]: ...
def get_waiting_message_count(self): ...
def cancel(self): ...
def basic_ack(self, delivery_tag: int = ..., multiple: bool = ...) -> None: ...
def basic_nack(self, delivery_tag: int = ..., multiple: bool = ..., requeue: bool = ...) -> None: ...
def basic_get(self, queue, auto_ack: bool = ...): ...
def basic_ack(self, delivery_tag: int = 0, multiple: bool = False) -> None: ...
def basic_nack(self, delivery_tag: int = 0, multiple: bool = False, requeue: bool = True) -> None: ...
def basic_get(self, queue, auto_ack: bool = False): ...
def basic_publish(
self, exchange: str, routing_key: str, body: str | bytes, properties: BasicProperties | None = ..., mandatory: bool = ...
self,
exchange: str,
routing_key: str,
body: str | bytes,
properties: BasicProperties | None = None,
mandatory: bool = False,
) -> None: ...
def basic_qos(self, prefetch_size: int = ..., prefetch_count: int = ..., global_qos: bool = ...) -> None: ...
def basic_recover(self, requeue: bool = ...) -> None: ...
def basic_reject(self, delivery_tag: int = ..., requeue: bool = ...) -> None: ...
def basic_qos(self, prefetch_size: int = 0, prefetch_count: int = 0, global_qos: bool = False) -> None: ...
def basic_recover(self, requeue: bool = False) -> None: ...
def basic_reject(self, delivery_tag: int = 0, requeue: bool = True) -> None: ...
def confirm_delivery(self) -> None: ...
def exchange_declare(
self,
exchange: str,
exchange_type: ExchangeType | str = ...,
passive: bool = ...,
durable: bool = ...,
auto_delete: bool = ...,
internal: bool = ...,
arguments: _ArgumentMapping | None = ...,
passive: bool = False,
durable: bool = False,
auto_delete: bool = False,
internal: bool = False,
arguments: _ArgumentMapping | None = None,
): ...
def exchange_delete(self, exchange: str | None = ..., if_unused: bool = ...): ...
def exchange_bind(self, destination, source, routing_key: str = ..., arguments: Incomplete | None = ...): ...
def exchange_delete(self, exchange: str | None = None, if_unused: bool = False): ...
def exchange_bind(self, destination, source, routing_key: str = "", arguments: Incomplete | None = None): ...
def exchange_unbind(
self,
destination: Incomplete | None = ...,
source: Incomplete | None = ...,
routing_key: str = ...,
arguments: Incomplete | None = ...,
destination: Incomplete | None = None,
source: Incomplete | None = None,
routing_key: str = "",
arguments: Incomplete | None = None,
): ...
def queue_declare(
self,
queue,
passive: bool = ...,
durable: bool = ...,
exclusive: bool = ...,
auto_delete: bool = ...,
arguments: Incomplete | None = ...,
passive: bool = False,
durable: bool = False,
exclusive: bool = False,
auto_delete: bool = False,
arguments: Incomplete | None = None,
): ...
def queue_delete(self, queue, if_unused: bool = ..., if_empty: bool = ...): ...
def queue_delete(self, queue, if_unused: bool = False, if_empty: bool = False): ...
def queue_purge(self, queue): ...
def queue_bind(self, queue, exchange, routing_key: Incomplete | None = ..., arguments: Incomplete | None = ...): ...
def queue_bind(self, queue, exchange, routing_key: Incomplete | None = None, arguments: Incomplete | None = None): ...
def queue_unbind(
self, queue, exchange: Incomplete | None = ..., routing_key: Incomplete | None = ..., arguments: Incomplete | None = ...
self,
queue,
exchange: Incomplete | None = None,
routing_key: Incomplete | None = None,
arguments: Incomplete | None = None,
): ...
def tx_select(self): ...
def tx_commit(self): ...
stubs/pika/pika/adapters/select_connection.pyi
+7 -7
View File
@@ -11,16 +11,16 @@ SELECT_TYPE: Incomplete
class SelectConnection(BaseConnection):
def __init__(
self,
parameters: Incomplete | None = ...,
on_open_callback: Incomplete | None = ...,
on_open_error_callback: Incomplete | None = ...,
on_close_callback: Incomplete | None = ...,
custom_ioloop: Incomplete | None = ...,
internal_connection_workflow: bool = ...,
parameters: Incomplete | None = None,
on_open_callback: Incomplete | None = None,
on_open_error_callback: Incomplete | None = None,
on_close_callback: Incomplete | None = None,
custom_ioloop: Incomplete | None = None,
internal_connection_workflow: bool = True,
) -> None: ...
@classmethod
def create_connection(
cls, connection_configs, on_done, custom_ioloop: Incomplete | None = ..., workflow: Incomplete | None = ...
cls, connection_configs, on_done, custom_ioloop: Incomplete | None = None, workflow: Incomplete | None = None
): ...
class _Timeout:
stubs/pika/pika/adapters/utils/connection_workflow.pyi
+1 -1
View File
@@ -31,7 +31,7 @@ class AbstractAMQPConnectionWorkflow(pika.compat.AbstractBase):
def abort(self) -> None: ...
class AMQPConnectionWorkflow(AbstractAMQPConnectionWorkflow):
def __init__(self, _until_first_amqp_attempt: bool = ...) -> None: ...
def __init__(self, _until_first_amqp_attempt: bool = False) -> None: ...
def set_io_services(self, nbio) -> None: ...
def start(self, connection_configs, connector_factory, native_loop, on_done) -> None: ...
def abort(self) -> None: ...
stubs/pika/pika/adapters/utils/io_services_utils.pyi
+1 -1
View File
@@ -11,7 +11,7 @@ class SocketConnectionMixin:
class StreamingConnectionMixin:
def create_streaming_connection(
self, protocol_factory, sock, on_done, ssl_context: Incomplete | None = ..., server_hostname: Incomplete | None = ...
self, protocol_factory, sock, on_done, ssl_context: Incomplete | None = None, server_hostname: Incomplete | None = None
): ...
class _AsyncServiceAsyncHandle(AbstractIOReference):
stubs/pika/pika/adapters/utils/nbio_interface.pyi
+2 -2
View File
@@ -17,12 +17,12 @@ class AbstractIOServices(pika.compat.AbstractBase, metaclass=abc.ABCMeta):
@abc.abstractmethod
def call_later(self, delay, callback): ...
@abc.abstractmethod
def getaddrinfo(self, host, port, on_done, family: int = ..., socktype: int = ..., proto: int = ..., flags: int = ...): ...
def getaddrinfo(self, host, port, on_done, family: int = 0, socktype: int = 0, proto: int = 0, flags: int = 0): ...
@abc.abstractmethod
def connect_socket(self, sock, resolved_addr, on_done): ...
@abc.abstractmethod
def create_streaming_connection(
self, protocol_factory, sock, on_done, ssl_context: Incomplete | None = ..., server_hostname: Incomplete | None = ...
self, protocol_factory, sock, on_done, ssl_context: Incomplete | None = None, server_hostname: Incomplete | None = None
): ...
class AbstractFileDescriptorServices(pika.compat.AbstractBase, metaclass=abc.ABCMeta):
stubs/pika/pika/adapters/utils/selector_ioloop_adapter.pyi
+2 -2
View File
@@ -47,7 +47,7 @@ class SelectorIOServicesAdapter(
def stop(self) -> None: ...
def add_callback_threadsafe(self, callback) -> None: ...
def call_later(self, delay, callback): ...
def getaddrinfo(self, host, port, on_done, family: int = ..., socktype: int = ..., proto: int = ..., flags: int = ...): ...
def getaddrinfo(self, host, port, on_done, family: int = 0, socktype: int = 0, proto: int = 0, flags: int = 0): ...
def set_reader(self, fd, on_readable) -> None: ...
def remove_reader(self, fd): ...
def set_writer(self, fd, on_writable) -> None: ...
@@ -56,7 +56,7 @@ class SelectorIOServicesAdapter(
class _FileDescriptorCallbacks:
reader: Incomplete
writer: Incomplete
def __init__(self, reader: Incomplete | None = ..., writer: Incomplete | None = ...) -> None: ...
def __init__(self, reader: Incomplete | None = None, writer: Incomplete | None = None) -> None: ...
class _TimerHandle(nbio_interface.AbstractTimerReference):
def __init__(self, handle, loop) -> None: ...
stubs/pika/pika/callback.pyi
+4 -4
View File
@@ -19,13 +19,13 @@ class CallbackManager:
prefix,
key,
callback,
one_shot: bool = ...,
only_caller: Incomplete | None = ...,
arguments: Incomplete | None = ...,
one_shot: bool = True,
only_caller: Incomplete | None = None,
arguments: Incomplete | None = None,
): ...
def clear(self) -> None: ...
def cleanup(self, prefix): ...
def pending(self, prefix, key): ...
def process(self, prefix, key, caller, *args, **keywords): ...
def remove(self, prefix, key, callback_value: Incomplete | None = ..., arguments: Incomplete | None = ...): ...
def remove(self, prefix, key, callback_value: Incomplete | None = None, arguments: Incomplete | None = None): ...
def remove_all(self, prefix, key) -> None: ...
stubs/pika/pika/channel.pyi
+64 -57
View File
@@ -27,46 +27,53 @@ class Channel:
def __init__(self, connection: Connection, channel_number: int, on_open_callback: Callable[[Self], object]) -> None: ...
def __int__(self) -> int: ...
def add_callback(self, callback, replies, one_shot: bool = ...) -> None: ...
def add_callback(self, callback, replies, one_shot: bool = True) -> None: ...
def add_on_cancel_callback(self, callback) -> None: ...
def add_on_close_callback(self, callback) -> None: ...
def add_on_flow_callback(self, callback) -> None: ...
def add_on_return_callback(self, callback) -> None: ...
def basic_ack(self, delivery_tag: int = ..., multiple: bool = ...) -> None: ...
def basic_ack(self, delivery_tag: int = 0, multiple: bool = False) -> None: ...
def basic_cancel(
self, consumer_tag: str = ..., callback: Callable[[Method[Basic.CancelOk]], object] | None = ...
self, consumer_tag: str = "", callback: Callable[[Method[Basic.CancelOk]], object] | None = None
) -> None: ...
def basic_consume(
self,
queue: str,
on_message_callback: Callable[[Channel, Basic.Deliver, BasicProperties, bytes], object],
auto_ack: bool = ...,
exclusive: bool = ...,
consumer_tag: str | None = ...,
arguments: _ArgumentMapping | None = ...,
callback: Callable[[Method[Basic.ConsumeOk]], object] | None = ...,
auto_ack: bool = False,
exclusive: bool = False,
consumer_tag: str | None = None,
arguments: _ArgumentMapping | None = None,
callback: Callable[[Method[Basic.ConsumeOk]], object] | None = None,
) -> str: ...
def basic_get(
self, queue: str, callback: Callable[[Channel, Basic.GetOk, BasicProperties, bytes], object], auto_ack: bool = ...
self, queue: str, callback: Callable[[Channel, Basic.GetOk, BasicProperties, bytes], object], auto_ack: bool = False
) -> None: ...
def basic_nack(self, delivery_tag: int = ..., multiple: bool = ..., requeue: bool = ...) -> None: ...
def basic_nack(self, delivery_tag: int = 0, multiple: bool = False, requeue: bool = True) -> None: ...
def basic_publish(
self, exchange: str, routing_key: str, body: str | bytes, properties: BasicProperties | None = ..., mandatory: bool = ...
self,
exchange: str,
routing_key: str,
body: str | bytes,
properties: BasicProperties | None = None,
mandatory: bool = False,
) -> None: ...
def basic_qos(
self,
prefetch_size: int = ...,
prefetch_count: int = ...,
global_qos: bool = ...,
callback: Callable[[Method[Basic.QosOk]], object] | None = ...,
prefetch_size: int = 0,
prefetch_count: int = 0,
global_qos: bool = False,
callback: Callable[[Method[Basic.QosOk]], object] | None = None,
) -> None: ...
def basic_reject(self, delivery_tag: int = ..., requeue: bool = ...) -> None: ...
def basic_recover(self, requeue: bool = ..., callback: Callable[[Method[Basic.RecoverOk]], object] | None = ...) -> None: ...
def close(self, reply_code: int = ..., reply_text: str = ...) -> None: ...
def basic_reject(self, delivery_tag: int = 0, requeue: bool = True) -> None: ...
def basic_recover(
self, requeue: bool = False, callback: Callable[[Method[Basic.RecoverOk]], object] | None = None
) -> None: ...
def close(self, reply_code: int = 0, reply_text: str = "Normal shutdown") -> None: ...
def confirm_delivery(
self,
ack_nack_callback: Callable[[Method[Basic.Ack | Basic.Nack]], object],
callback: Callable[[Method[Confirm.SelectOk]], object] | None = ...,
callback: Callable[[Method[Confirm.SelectOk]], object] | None = None,
) -> None: ...
@property
def consumer_tags(self) -> list[str]: ...
@@ -74,36 +81,36 @@ class Channel:
self,
destination: str,
source: str,
routing_key: str = ...,
arguments: _ArgumentMapping | None = ...,
callback: Callable[[Method[Exchange.BindOk]], object] | None = ...,
routing_key: str = "",
arguments: _ArgumentMapping | None = None,
callback: Callable[[Method[Exchange.BindOk]], object] | None = None,
) -> None: ...
def exchange_declare(
self,
exchange: str,
exchange_type: ExchangeType | str = ...,
passive: bool = ...,
durable: bool = ...,
auto_delete: bool = ...,
internal: bool = ...,
arguments: _ArgumentMapping | None = ...,
callback: Callable[[Method[Exchange.DeclareOk]], object] | None = ...,
passive: bool = False,
durable: bool = False,
auto_delete: bool = False,
internal: bool = False,
arguments: _ArgumentMapping | None = None,
callback: Callable[[Method[Exchange.DeclareOk]], object] | None = None,
) -> None: ...
def exchange_delete(
self,
exchange: str | None = ...,
if_unused: bool = ...,
callback: Callable[[Method[Exchange.DeleteOk]], object] | None = ...,
exchange: str | None = None,
if_unused: bool = False,
callback: Callable[[Method[Exchange.DeleteOk]], object] | None = None,
) -> None: ...
def exchange_unbind(
self,
destination: str | None = ...,
source: str | None = ...,
routing_key: str = ...,
arguments: _ArgumentMapping | None = ...,
callback: Callable[[Method[Exchange.UnbindOk]], object] | None = ...,
destination: str | None = None,
source: str | None = None,
routing_key: str = "",
arguments: _ArgumentMapping | None = None,
callback: Callable[[Method[Exchange.UnbindOk]], object] | None = None,
) -> None: ...
def flow(self, active: bool, callback: Callable[[bool], object] | None = ...) -> None: ...
def flow(self, active: bool, callback: Callable[[bool], object] | None = None) -> None: ...
@property
def is_closed(self) -> bool: ...
@property
@@ -117,39 +124,39 @@ class Channel:
self,
queue: str,
exchange: str,
routing_key: str | None = ...,
arguments: _ArgumentMapping | None = ...,
callback: Callable[[Method[Queue.BindOk]], object] | None = ...,
routing_key: str | None = None,
arguments: _ArgumentMapping | None = None,
callback: Callable[[Method[Queue.BindOk]], object] | None = None,
) -> None: ...
def queue_declare(
self,
queue: str,
passive: bool = ...,
durable: bool = ...,
exclusive: bool = ...,
auto_delete: bool = ...,
arguments: _ArgumentMapping | None = ...,
callback: Callable[[Method[Queue.DeclareOk]], object] | None = ...,
passive: bool = False,
durable: bool = False,
exclusive: bool = False,
auto_delete: bool = False,
arguments: _ArgumentMapping | None = None,
callback: Callable[[Method[Queue.DeclareOk]], object] | None = None,
) -> None: ...
def queue_delete(
self,
queue: str,
if_unused: bool = ...,
if_empty: bool = ...,
callback: Callable[[Method[Queue.DeleteOk]], object] | None = ...,
if_unused: bool = False,
if_empty: bool = False,
callback: Callable[[Method[Queue.DeleteOk]], object] | None = None,
) -> None: ...
def queue_purge(self, queue: str, callback: Callable[[Method[Queue.PurgeOk]], object] | None = ...) -> None: ...
def queue_purge(self, queue: str, callback: Callable[[Method[Queue.PurgeOk]], object] | None = None) -> None: ...
def queue_unbind(
self,
queue: str,
exchange: str | None = ...,
routing_key: str | None = ...,
arguments: _ArgumentMapping | None = ...,
callback: Callable[[Method[Queue.UnbindOk]], object] | None = ...,
exchange: str | None = None,
routing_key: str | None = None,
arguments: _ArgumentMapping | None = None,
callback: Callable[[Method[Queue.UnbindOk]], object] | None = None,
): ...
def tx_commit(self, callback: Callable[[Method[Tx.CommitOk]], object] | None = ...) -> None: ...
def tx_rollback(self, callback: Callable[[Method[Tx.RollbackOk]], object] | None = ...) -> None: ...
def tx_select(self, callback: Callable[[Method[Tx.SelectOk]], object] | None = ...) -> None: ...
def tx_commit(self, callback: Callable[[Method[Tx.CommitOk]], object] | None = None) -> None: ...
def tx_rollback(self, callback: Callable[[Method[Tx.RollbackOk]], object] | None = None) -> None: ...
def tx_select(self, callback: Callable[[Method[Tx.SelectOk]], object] | None = None) -> None: ...
class ContentFrameAssembler:
def __init__(self) -> None: ...
stubs/pika/pika/connection.pyi
+10 -10
View File
@@ -130,7 +130,7 @@ class URLParameters(Parameters):
class SSLOptions:
context: Incomplete
server_hostname: Incomplete
def __init__(self, context, server_hostname: Incomplete | None = ...) -> None: ...
def __init__(self, context, server_hostname: Incomplete | None = None) -> None: ...
class Connection(AbstractBase, metaclass=abc.ABCMeta):
ON_CONNECTION_CLOSED: Final[str]
@@ -151,11 +151,11 @@ class Connection(AbstractBase, metaclass=abc.ABCMeta):
known_hosts: Incomplete
def __init__(
self,
parameters: Parameters | None = ...,
on_open_callback: Callable[[Self], object] | None = ...,
on_open_error_callback: Callable[[Self, BaseException], object] | None = ...,
on_close_callback: Callable[[Self, BaseException], object] | None = ...,
internal_connection_workflow: bool = ...,
parameters: Parameters | None = None,
on_open_callback: Callable[[Self], object] | None = None,
on_open_error_callback: Callable[[Self, BaseException], object] | None = None,
on_close_callback: Callable[[Self, BaseException], object] | None = None,
internal_connection_workflow: bool = True,
) -> None: ...
def add_on_close_callback(self, callback: Callable[[Self, BaseException], object]) -> None: ...
def add_on_connection_blocked_callback(self, callback: Callable[[Self, Method[SpecConnection.Blocked]], object]) -> None: ...
@@ -164,13 +164,13 @@ class Connection(AbstractBase, metaclass=abc.ABCMeta):
) -> None: ...
def add_on_open_callback(self, callback: Callable[[Self], object]) -> None: ...
def add_on_open_error_callback(
self, callback: Callable[[Self, BaseException], object], remove_default: bool = ...
self, callback: Callable[[Self, BaseException], object], remove_default: bool = True
) -> None: ...
def channel(
self, channel_number: int | None = ..., on_open_callback: Callable[[Channel], object] | None = ...
self, channel_number: int | None = None, on_open_callback: Callable[[Channel], object] | None = None
) -> Channel: ...
def update_secret(self, new_secret, reason, callback: Incomplete | None = ...) -> None: ...
def close(self, reply_code: int = ..., reply_text: str = ...) -> None: ...
def update_secret(self, new_secret, reason, callback: Incomplete | None = None) -> None: ...
def close(self, reply_code: int = 200, reply_text: str = "Normal shutdown") -> None: ...
@property
def is_closed(self) -> bool: ...
@property
stubs/pika/pika/credentials.pyi
+1 -1
View File
@@ -15,7 +15,7 @@ class PlainCredentials:
username: str
password: str
erase_on_connect: bool
def __init__(self, username: str, password: str, erase_on_connect: bool = ...) -> None: ...
def __init__(self, username: str, password: str, erase_on_connect: bool = False) -> None: ...
def __eq__(self, other: object) -> bool: ...
def __ne__(self, other: object) -> bool: ...
def response_for(self, start: Connection.Start) -> tuple[str | None, bytes | None]: ...
stubs/pika/pika/frame.pyi
+1 -1
View File
@@ -41,7 +41,7 @@ class ProtocolHeader(AMQPObject):
major: int
minor: int
revision: int
def __init__(self, major: int | None = ..., minor: int | None = ..., revision: int | None = ...) -> None: ...
def __init__(self, major: int | None = None, minor: int | None = None, revision: int | None = None) -> None: ...
def marshal(self) -> bytes: ...
def decode_frame(data_in: bytes) -> tuple[int, Frame | None]: ...
stubs/pika/pika/spec.pyi
+173 -173
View File
@@ -53,15 +53,15 @@ class Connection(Class):
locales: Incomplete
def __init__(
self,
version_major: int = ...,
version_minor: int = ...,
server_properties: Incomplete | None = ...,
version_major: int = 0,
version_minor: int = 9,
server_properties: Incomplete | None = None,
mechanisms: _str = ...,
locales: _str = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class StartOk(Method):
@@ -72,32 +72,32 @@ class Connection(Class):
locale: Incomplete
def __init__(
self,
client_properties: Incomplete | None = ...,
client_properties: Incomplete | None = None,
mechanism: _str = ...,
response: Incomplete | None = ...,
response: Incomplete | None = None,
locale: _str = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Secure(Method):
INDEX: ClassVar[int]
challenge: Incomplete
def __init__(self, challenge: Incomplete | None = ...) -> None: ...
def __init__(self, challenge: Incomplete | None = None) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class SecureOk(Method):
INDEX: ClassVar[int]
response: Incomplete
def __init__(self, response: Incomplete | None = ...) -> None: ...
def __init__(self, response: Incomplete | None = None) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Tune(Method):
@@ -105,10 +105,10 @@ class Connection(Class):
channel_max: Incomplete
frame_max: Incomplete
heartbeat: Incomplete
def __init__(self, channel_max: int = ..., frame_max: int = ..., heartbeat: int = ...) -> None: ...
def __init__(self, channel_max: int = 0, frame_max: int = 0, heartbeat: int = 0) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class TuneOk(Method):
@@ -116,10 +116,10 @@ class Connection(Class):
channel_max: Incomplete
frame_max: Incomplete
heartbeat: Incomplete
def __init__(self, channel_max: int = ..., frame_max: int = ..., heartbeat: int = ...) -> None: ...
def __init__(self, channel_max: int = 0, frame_max: int = 0, heartbeat: int = 0) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Open(Method):
@@ -127,10 +127,10 @@ class Connection(Class):
virtual_host: Incomplete
capabilities: Incomplete
insist: Incomplete
def __init__(self, virtual_host: _str = ..., capabilities: _str = ..., insist: bool = ...) -> None: ...
def __init__(self, virtual_host: _str = ..., capabilities: _str = ..., insist: bool = False) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class OpenOk(Method):
@@ -139,7 +139,7 @@ class Connection(Class):
def __init__(self, known_hosts: _str = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Close(Method):
@@ -150,14 +150,14 @@ class Connection(Class):
method_id: Incomplete
def __init__(
self,
reply_code: Incomplete | None = ...,
reply_code: Incomplete | None = None,
reply_text: _str = ...,
class_id: Incomplete | None = ...,
method_id: Incomplete | None = ...,
class_id: Incomplete | None = None,
method_id: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class CloseOk(Method):
@@ -165,7 +165,7 @@ class Connection(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Blocked(Method):
@@ -174,7 +174,7 @@ class Connection(Class):
def __init__(self, reason: _str = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Unblocked(Method):
@@ -182,7 +182,7 @@ class Connection(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class UpdateSecret(Method):
@@ -193,7 +193,7 @@ class Connection(Class):
@property
def synchronous(self): ...
mechanisms: Incomplete
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class UpdateSecretOk(Method):
@@ -201,7 +201,7 @@ class Connection(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Channel(Class):
@@ -213,7 +213,7 @@ class Channel(Class):
def __init__(self, out_of_band: _str = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class OpenOk(Method):
@@ -222,25 +222,25 @@ class Channel(Class):
def __init__(self, channel_id: _str = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Flow(Method):
INDEX: ClassVar[int]
active: Incomplete
def __init__(self, active: Incomplete | None = ...) -> None: ...
def __init__(self, active: Incomplete | None = None) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class FlowOk(Method):
INDEX: ClassVar[int]
active: Incomplete
def __init__(self, active: Incomplete | None = ...) -> None: ...
def __init__(self, active: Incomplete | None = None) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Close(Method):
@@ -251,14 +251,14 @@ class Channel(Class):
method_id: Incomplete
def __init__(
self,
reply_code: Incomplete | None = ...,
reply_code: Incomplete | None = None,
reply_text: _str = ...,
class_id: Incomplete | None = ...,
method_id: Incomplete | None = ...,
class_id: Incomplete | None = None,
method_id: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class CloseOk(Method):
@@ -266,7 +266,7 @@ class Channel(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Access(Class):
@@ -283,24 +283,24 @@ class Access(Class):
def __init__(
self,
realm: _str = ...,
exclusive: bool = ...,
passive: bool = ...,
active: bool = ...,
write: bool = ...,
read: bool = ...,
exclusive: bool = False,
passive: bool = True,
active: bool = True,
write: bool = True,
read: bool = True,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class RequestOk(Method):
INDEX: ClassVar[int]
ticket: Incomplete
def __init__(self, ticket: int = ...) -> None: ...
def __init__(self, ticket: int = 1) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Exchange(Class):
@@ -319,19 +319,19 @@ class Exchange(Class):
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
exchange: Incomplete | None = ...,
ticket: int = 0,
exchange: Incomplete | None = None,
type=...,
passive: bool = ...,
durable: bool = ...,
auto_delete: bool = ...,
internal: bool = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
passive: bool = False,
durable: bool = False,
auto_delete: bool = False,
internal: bool = False,
nowait: bool = False,
arguments: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class DeclareOk(Method):
@@ -339,7 +339,7 @@ class Exchange(Class):
def __init__(self) -> None: ...
@property
def synchronous(self) -> Literal[False]: ...
def decode(self, encoded: bytes, offset: int = ...) -> Self: ...
def decode(self, encoded: bytes, offset: int = 0) -> Self: ...
def encode(self) -> list[bytes]: ...
class Delete(Method):
@@ -349,11 +349,11 @@ class Exchange(Class):
if_unused: Incomplete
nowait: Incomplete
def __init__(
self, ticket: int = ..., exchange: Incomplete | None = ..., if_unused: bool = ..., nowait: bool = ...
self, ticket: int = 0, exchange: Incomplete | None = None, if_unused: bool = False, nowait: bool = False
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class DeleteOk(Method):
@@ -361,7 +361,7 @@ class Exchange(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Bind(Method):
@@ -374,16 +374,16 @@ class Exchange(Class):
arguments: Incomplete | None
def __init__(
self,
ticket: int = ...,
destination: Incomplete | None = ...,
source: Incomplete | None = ...,
ticket: int = 0,
destination: Incomplete | None = None,
source: Incomplete | None = None,
routing_key: _str = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
nowait: bool = False,
arguments: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class BindOk(Method):
@@ -391,7 +391,7 @@ class Exchange(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Unbind(Method):
@@ -404,16 +404,16 @@ class Exchange(Class):
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
destination: Incomplete | None = ...,
source: Incomplete | None = ...,
ticket: int = 0,
destination: Incomplete | None = None,
source: Incomplete | None = None,
routing_key: _str = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
nowait: bool = False,
arguments: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class UnbindOk(Method):
@@ -421,7 +421,7 @@ class Exchange(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Queue(Class):
@@ -439,18 +439,18 @@ class Queue(Class):
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
ticket: int = 0,
queue: _str = ...,
passive: bool = ...,
durable: bool = ...,
exclusive: bool = ...,
auto_delete: bool = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
passive: bool = False,
durable: bool = False,
exclusive: bool = False,
auto_delete: bool = False,
nowait: bool = False,
arguments: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self) -> Literal[True]: ...
def decode(self, encoded: bytes, offset: int = ...) -> Self: ...
def decode(self, encoded: bytes, offset: int = 0) -> Self: ...
def encode(self) -> list[bytes]: ...
class DeclareOk(Method):
@@ -461,7 +461,7 @@ class Queue(Class):
def __init__(self, queue: _str, message_count: int, consumer_count: int) -> None: ...
@property
def synchronous(self) -> Literal[False]: ...
def decode(self, encoded: bytes, offset: int = ...) -> Self: ...
def decode(self, encoded: bytes, offset: int = 0) -> Self: ...
def encode(self) -> list[bytes]: ...
class Bind(Method):
@@ -474,16 +474,16 @@ class Queue(Class):
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
ticket: int = 0,
queue: _str = ...,
exchange: Incomplete | None = ...,
exchange: Incomplete | None = None,
routing_key: _str = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
nowait: bool = False,
arguments: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class BindOk(Method):
@@ -491,7 +491,7 @@ class Queue(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Purge(Method):
@@ -499,19 +499,19 @@ class Queue(Class):
ticket: Incomplete
queue: Incomplete
nowait: Incomplete
def __init__(self, ticket: int = ..., queue: _str = ..., nowait: bool = ...) -> None: ...
def __init__(self, ticket: int = 0, queue: _str = ..., nowait: bool = False) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class PurgeOk(Method):
INDEX: ClassVar[int]
message_count: Incomplete
def __init__(self, message_count: Incomplete | None = ...) -> None: ...
def __init__(self, message_count: Incomplete | None = None) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Delete(Method):
@@ -522,20 +522,20 @@ class Queue(Class):
if_empty: Incomplete
nowait: Incomplete
def __init__(
self, ticket: int = ..., queue: _str = ..., if_unused: bool = ..., if_empty: bool = ..., nowait: bool = ...
self, ticket: int = 0, queue: _str = ..., if_unused: bool = False, if_empty: bool = False, nowait: bool = False
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class DeleteOk(Method):
INDEX: ClassVar[int]
message_count: Incomplete
def __init__(self, message_count: Incomplete | None = ...) -> None: ...
def __init__(self, message_count: Incomplete | None = None) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Unbind(Method):
@@ -547,15 +547,15 @@ class Queue(Class):
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
ticket: int = 0,
queue: _str = ...,
exchange: Incomplete | None = ...,
exchange: Incomplete | None = None,
routing_key: _str = ...,
arguments: Incomplete | None = ...,
arguments: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class UnbindOk(Method):
@@ -563,7 +563,7 @@ class Queue(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Basic(Class):
@@ -574,10 +574,10 @@ class Basic(Class):
prefetch_size: Incomplete
prefetch_count: Incomplete
global_qos: Incomplete
def __init__(self, prefetch_size: int = ..., prefetch_count: int = ..., global_qos: bool = ...) -> None: ...
def __init__(self, prefetch_size: int = 0, prefetch_count: int = 0, global_qos: bool = False) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class QosOk(Method):
@@ -585,7 +585,7 @@ class Basic(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Consume(Method):
@@ -600,46 +600,46 @@ class Basic(Class):
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
ticket: int = 0,
queue: _str = ...,
consumer_tag: _str = ...,
no_local: bool = ...,
no_ack: bool = ...,
exclusive: bool = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
no_local: bool = False,
no_ack: bool = False,
exclusive: bool = False,
nowait: bool = False,
arguments: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class ConsumeOk(Method):
INDEX: ClassVar[int]
consumer_tag: Incomplete
def __init__(self, consumer_tag: Incomplete | None = ...) -> None: ...
def __init__(self, consumer_tag: Incomplete | None = None) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Cancel(Method):
INDEX: ClassVar[int]
consumer_tag: Incomplete
nowait: Incomplete
def __init__(self, consumer_tag: Incomplete | None = ..., nowait: bool = ...) -> None: ...
def __init__(self, consumer_tag: Incomplete | None = None, nowait: bool = False) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class CancelOk(Method):
INDEX: ClassVar[int]
consumer_tag: Incomplete
def __init__(self, consumer_tag: Incomplete | None = ...) -> None: ...
def __init__(self, consumer_tag: Incomplete | None = None) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Publish(Method):
@@ -650,11 +650,11 @@ class Basic(Class):
mandatory: Incomplete
immediate: Incomplete
def __init__(
self, ticket: int = ..., exchange: _str = ..., routing_key: _str = ..., mandatory: bool = ..., immediate: bool = ...
self, ticket: int = 0, exchange: _str = ..., routing_key: _str = ..., mandatory: bool = False, immediate: bool = False
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Return(Method):
@@ -665,14 +665,14 @@ class Basic(Class):
routing_key: Incomplete
def __init__(
self,
reply_code: Incomplete | None = ...,
reply_code: Incomplete | None = None,
reply_text: _str = ...,
exchange: Incomplete | None = ...,
routing_key: Incomplete | None = ...,
exchange: Incomplete | None = None,
routing_key: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Deliver(Method):
@@ -684,15 +684,15 @@ class Basic(Class):
routing_key: Incomplete
def __init__(
self,
consumer_tag: Incomplete | None = ...,
delivery_tag: Incomplete | None = ...,
redelivered: bool = ...,
exchange: Incomplete | None = ...,
routing_key: Incomplete | None = ...,
consumer_tag: Incomplete | None = None,
delivery_tag: Incomplete | None = None,
redelivered: bool = False,
exchange: Incomplete | None = None,
routing_key: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Get(Method):
@@ -700,10 +700,10 @@ class Basic(Class):
ticket: Incomplete
queue: Incomplete
no_ack: Incomplete
def __init__(self, ticket: int = ..., queue: _str = ..., no_ack: bool = ...) -> None: ...
def __init__(self, ticket: int = 0, queue: _str = ..., no_ack: bool = False) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class GetOk(Method):
@@ -715,15 +715,15 @@ class Basic(Class):
message_count: Incomplete
def __init__(
self,
delivery_tag: Incomplete | None = ...,
redelivered: bool = ...,
exchange: Incomplete | None = ...,
routing_key: Incomplete | None = ...,
message_count: Incomplete | None = ...,
delivery_tag: Incomplete | None = None,
redelivered: bool = False,
exchange: Incomplete | None = None,
routing_key: Incomplete | None = None,
message_count: Incomplete | None = None,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class GetEmpty(Method):
@@ -732,45 +732,45 @@ class Basic(Class):
def __init__(self, cluster_id: _str = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Ack(Method):
INDEX: ClassVar[int]
delivery_tag: Incomplete
multiple: Incomplete
def __init__(self, delivery_tag: int = ..., multiple: bool = ...) -> None: ...
def __init__(self, delivery_tag: int = 0, multiple: bool = False) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Reject(Method):
INDEX: ClassVar[int]
delivery_tag: Incomplete
requeue: Incomplete
def __init__(self, delivery_tag: Incomplete | None = ..., requeue: bool = ...) -> None: ...
def __init__(self, delivery_tag: Incomplete | None = None, requeue: bool = True) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class RecoverAsync(Method):
INDEX: ClassVar[int]
requeue: Incomplete
def __init__(self, requeue: bool = ...) -> None: ...
def __init__(self, requeue: bool = False) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Recover(Method):
INDEX: ClassVar[int]
requeue: Incomplete
def __init__(self, requeue: bool = ...) -> None: ...
def __init__(self, requeue: bool = False) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class RecoverOk(Method):
@@ -778,7 +778,7 @@ class Basic(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Nack(Method):
@@ -786,10 +786,10 @@ class Basic(Class):
delivery_tag: Incomplete
multiple: Incomplete
requeue: Incomplete
def __init__(self, delivery_tag: int = ..., multiple: bool = ..., requeue: bool = ...) -> None: ...
def __init__(self, delivery_tag: int = 0, multiple: bool = False, requeue: bool = True) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Tx(Class):
@@ -800,7 +800,7 @@ class Tx(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class SelectOk(Method):
@@ -808,7 +808,7 @@ class Tx(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Commit(Method):
@@ -816,7 +816,7 @@ class Tx(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class CommitOk(Method):
@@ -824,7 +824,7 @@ class Tx(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Rollback(Method):
@@ -832,7 +832,7 @@ class Tx(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class RollbackOk(Method):
@@ -840,7 +840,7 @@ class Tx(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class Confirm(Class):
@@ -849,10 +849,10 @@ class Confirm(Class):
class Select(Method):
INDEX: ClassVar[int]
nowait: Incomplete
def __init__(self, nowait: bool = ...) -> None: ...
def __init__(self, nowait: bool = False) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class SelectOk(Method):
@@ -860,7 +860,7 @@ class Confirm(Class):
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
class BasicProperties(Properties):
@@ -896,22 +896,22 @@ class BasicProperties(Properties):
cluster_id: Incomplete
def __init__(
self,
content_type: Incomplete | None = ...,
content_encoding: Incomplete | None = ...,
headers: Incomplete | None = ...,
delivery_mode: Incomplete | None = ...,
priority: Incomplete | None = ...,
correlation_id: Incomplete | None = ...,
reply_to: Incomplete | None = ...,
expiration: Incomplete | None = ...,
message_id: Incomplete | None = ...,
timestamp: Incomplete | None = ...,
type: Incomplete | None = ...,
user_id: Incomplete | None = ...,
app_id: Incomplete | None = ...,
cluster_id: Incomplete | None = ...,
content_type: Incomplete | None = None,
content_encoding: Incomplete | None = None,
headers: Incomplete | None = None,
delivery_mode: Incomplete | None = None,
priority: Incomplete | None = None,
correlation_id: Incomplete | None = None,
reply_to: Incomplete | None = None,
expiration: Incomplete | None = None,
message_id: Incomplete | None = None,
timestamp: Incomplete | None = None,
type: Incomplete | None = None,
user_id: Incomplete | None = None,
app_id: Incomplete | None = None,
cluster_id: Incomplete | None = None,
) -> None: ...
def decode(self, encoded, offset: int = ...): ...
def decode(self, encoded, offset: int = 0): ...
def encode(self): ...
methods: Incomplete
stubs/pika/pika/validators.pyi
+1 -1
View File
@@ -1,4 +1,4 @@
def require_string(value, value_name) -> None: ...
def require_callback(callback, callback_name: str = ...) -> None: ...
def require_callback(callback, callback_name: str = "callback") -> None: ...
def rpc_completion_callback(callback): ...
def zero_or_greater(name, value) -> None: ...