remcall.communication package

Submodules

remcall.communication.base module

remcall.communication.bridge module

class remcall.communication.bridge.Bridge(schema, instream, outstream, main, enum_record_implementation: remcall.implementation.EnumRecordImplementation)[source]

Bases: object

acknowledge_disconnect()[source]
call_method(method, this, args_dict)[source]
disconnect()[source]
return_method(request_id: int, return_type: remcall.schema.core.Type, return_value)[source]

remcall.communication.proxy module

class remcall.communication.proxy.MethodProxy(interface, method, bridge, name_converter)[source]

Bases: object

class remcall.communication.proxy.ProxyFactory(schema, bridge, name_converter)[source]

Bases: object

class remcall.communication.proxy.ProxyType[source]

Bases: object

remcall.communication.proxy.create_proxy_class(interface, bridge, name_converter)[source]
remcall.communication.proxy.create_proxy_classes(schema, bridge)[source]
remcall.communication.proxy.create_proxy_classes_dict(schema, bridge, name_converter)[source]

remcall.communication.receive module

class remcall.communication.receive.Receiver(schema, instream, get_object, return_method_result, acknowledge_disconnect, name_converter)[source]

Bases: remcall.codec.read.ReaderBase

mainloop()[source]
process_method_call()[source]
process_method_return()[source]
process_next()[source]
read_enum_value(typ: remcall.schema.core.Type)[source]
read_from_stream(bytes_count: int)[source]
read_method_ref()[source]
read_object(typ: remcall.schema.core.Type)[source]
read_object_ref(typ: remcall.schema.core.Type)[source]
read_request_id()[source]
read_value(typ: remcall.schema.core.Type)[source]
receive_and_check_schema()[source]
wait_for_method_return(request_id, return_type)[source]

remcall.communication.send module

class remcall.communication.send.Sender(schema, outstream, get_id_for_object)[source]

Bases: remcall.codec.write.WriterBase

acknowledge_disconnect()[source]
call_method(method, this, args_dict)[source]
disconnect()[source]
noop()[source]
request_schema()[source]
return_method(request_id, return_type, return_value)[source]
send_schema()[source]
write_enum_value(enum_value)[source]
write_object_ref(obj)[source]
write_record_value(val)[source]
write_request_id(request_id=None)[source]
write_to_stream(data: bytes)[source]
write_value(typ, value)[source]

remcall.communication.store module

class remcall.communication.store.IdStore[source]

Bases: object

contains_object(obj)[source]
delete_object(obj)[source]
get_id_for_object(obj)[source]
class remcall.communication.store.ReferenceStore(is_client, proxy_factory)[source]

Bases: object

get_id_for_implementation_object(obj)[source]
get_id_for_object(obj)[source]
get_id_for_proxy_object(obj)[source]
get_implementation_object(key: int)[source]
get_object(key: int, typ: remcall.schema.core.Type)[source]
get_proxy_object(key: int, typ: remcall.schema.core.Type)[source]
next_object_id()[source]
object_id_sign

Module contents