37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
+
+
+
-
+
+
+
+
-
+
+
+
+
+
+
-
+
+
+
+
+
-
+
+
+
+
+
+
-
+
+
+
+
+
+
-
+
+
+
+
+
+
+
-
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
-
-
-
-
-
-
+
+
|
+ (void)of_setMainRunLoop: (OFRunLoop *)runLoop;
#ifdef OF_HAVE_SOCKETS
+ (void)of_addAsyncReadForStream: (OFStream <OFReadyForReadingObserving> *)
stream
buffer: (void *)buffer
length: (size_t)length
mode: (of_run_loop_mode_t)mode
# ifdef OF_HAVE_BLOCKS
block: (nullable of_stream_async_read_block_t)block
# endif
delegate: (id <OFStreamDelegate>)delegate;
delegate: (nullable id <OFStreamDelegate>)delegate;
+ (void)of_addAsyncReadForStream: (OFStream <OFReadyForReadingObserving> *)
stream
buffer: (void *)buffer
exactLength: (size_t)length
mode: (of_run_loop_mode_t)mode
# ifdef OF_HAVE_BLOCKS
block: (nullable of_stream_async_read_block_t)block
# endif
delegate: (id <OFStreamDelegate>)delegate;
delegate: (nullable id <OFStreamDelegate>)delegate;
+ (void)of_addAsyncReadLineForStream: (OFStream <OFReadyForReadingObserving> *)
stream
encoding: (of_string_encoding_t)encoding
mode: (of_run_loop_mode_t)mode
# ifdef OF_HAVE_BLOCKS
block: (nullable
of_stream_async_read_line_block_t)
block
# endif
delegate: (id <OFStreamDelegate>)delegate;
delegate: (nullable id <OFStreamDelegate>)delegate;
+ (void)of_addAsyncWriteForStream: (OFStream <OFReadyForWritingObserving> *)
stream
data: (OFData *)data
mode: (of_run_loop_mode_t)mode
# ifdef OF_HAVE_BLOCKS
block: (nullable of_stream_async_write_data_block_t)
block
# endif
delegate: (id <OFStreamDelegate>)delegate;
delegate: (nullable id <OFStreamDelegate>)delegate;
+ (void)of_addAsyncWriteForStream: (OFStream <OFReadyForWritingObserving> *)
stream
string: (OFString *)string
encoding: (of_string_encoding_t)encoding
mode: (of_run_loop_mode_t)mode
# ifdef OF_HAVE_BLOCKS
block: (nullable
of_stream_async_write_string_block_t)
block
# endif
delegate: (id <OFStreamDelegate>)delegate;
delegate: (nullable id <OFStreamDelegate>)delegate;
+ (void)of_addAsyncConnectForTCPSocket: (OFTCPSocket *)socket
mode: (of_run_loop_mode_t)mode
delegate: (id <OFTCPSocketDelegate_Private>)
delegate;
+ (void)of_addAsyncAcceptForTCPSocket: (OFTCPSocket *)socket
mode: (of_run_loop_mode_t)mode
# ifdef OF_HAVE_BLOCKS
block: (nullable
of_tcp_socket_async_accept_block_t)
block
# endif
delegate: (id <OFTCPSocketDelegate>)delegate;
delegate: (nullable id <OFTCPSocketDelegate>)
delegate;
+ (void)of_addAsyncReceiveForUDPSocket: (OFUDPSocket *)socket
buffer: (void *)buffer
length: (size_t)length
mode: (of_run_loop_mode_t)mode
# ifdef OF_HAVE_BLOCKS
block: (nullable
of_udp_socket_async_receive_block_t)
block
# endif
delegate: (id <OFUDPSocketDelegate>)delegate;
delegate: (nullable id <OFUDPSocketDelegate>)
delegate;
+ (void)of_addAsyncSendForUDPSocket: (OFUDPSocket *)socket
buffer: (const void *)buffer
length: (size_t)length
receiver: (of_socket_address_t)receiver
mode: (of_run_loop_mode_t)mode
delegate: (id <OFUDPSocketDelegate>)delegate;
+ (void)of_addAsyncReadForStream: (OFStream <OFReadyForReadingObserving> *)
stream
buffer: (void *)buffer
length: (size_t)length
mode: (of_run_loop_mode_t)mode
block: (of_stream_async_read_block_t)block;
+ (void)of_addAsyncReadForStream: (OFStream <OFReadyForReadingObserving> *)
stream
buffer: (void *)buffer
exactLength: (size_t)length
mode: (of_run_loop_mode_t)mode
block: (of_stream_async_read_block_t)block;
+ (void)of_addAsyncReadLineForStream: (OFStream <OFReadyForReadingObserving> *)
stream
encoding: (of_string_encoding_t)encoding
mode: (of_run_loop_mode_t)mode
block: (of_stream_async_read_line_block_t)block;
+ (void)of_addAsyncWriteForStream: (OFStream <OFReadyForWritingObserving> *)
stream
data: (OFData *)data
mode: (of_run_loop_mode_t)mode
block: (of_stream_async_write_data_block_t)block;
+ (void)of_addAsyncWriteForStream: (OFStream <OFReadyForWritingObserving> *)
stream
string: (OFString *)string
encoding: (of_string_encoding_t)encoding
mode: (of_run_loop_mode_t)mode
block: (of_stream_async_write_string_block_t)block;
+ (void)of_addAsyncAcceptForTCPSocket: (OFTCPSocket *)socket
mode: (of_run_loop_mode_t)mode
block: (of_tcp_socket_async_accept_block_t)
block;
+ (void)of_addAsyncReceiveForUDPSocket: (OFUDPSocket *)socket
buffer: (void *)buffer
length: (size_t)length
mode: (of_run_loop_mode_t)mode
block: (of_udp_socket_async_receive_block_t)
block;
+ (void)of_addAsyncSendForUDPSocket: (OFUDPSocket *)socket
buffer: (const void *)buffer
length: (size_t)length
receiver: (of_socket_address_t)receiver
mode: (of_run_loop_mode_t)mode
block: (of_udp_socket_async_send_block_t)block;
|