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
|
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
|
-
+
-
+
-
+
|
#else
@protocol OFStreamObserverDelegate
#endif
#ifdef OF_HAVE_OPTIONAL_PROTOCOLS
@optional
#endif
/**
* This callback is called when a stream did get ready for reading.
* \brief This callback is called when a stream did get ready for reading.
*
* \param stream The stream which did become ready for reading
*/
- (void)streamDidBecomeReadyForReading: (OFStream*)stream;
/**
* This callback is called when a stream did get ready for writing.
* \brief This callback is called when a stream did get ready for writing.
*
* \param stream The stream which did become ready for writing
*/
- (void)streamDidBecomeReadyForWriting: (OFStream*)stream;
/**
* This callback is called when an exception occurred on the stream.
* \brief This callback is called when an exception occurred on the stream.
*
* \param stream The stream on which an exception occurred
*/
- (void)streamDidReceiveException: (OFStream*)stream;
@end
/**
|
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
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
|
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
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
|
+
+
+
+
-
+
-
+
-
+
-
+
-
+
-
+
-
-
+
+
|
}
#ifdef OF_HAVE_PROPERTIES
@property (retain) id <OFStreamObserverDelegate> delegate;
#endif
/**
* \brief Creates a new OFStreamObserver.
*
* \return A new, autoreleased OFStreamObserver
*/
+ observer;
/**
* \brief Returns the delegate for the OFStreamObserver.
*
* \return The delegate for the OFStreamObserver
*/
- (id <OFStreamObserverDelegate>)delegate;
/**
* Sets the delegate for the OFStreamObserver.
* \brief Sets the delegate for the OFStreamObserver.
*
* \param delegate The delegate for the OFStreamObserver
*/
- (void)setDelegate: (id <OFStreamObserverDelegate>)delegate;
/**
* Adds a stream to observe for reading.
* \brief Adds a stream to observe for reading.
*
* This is also used to observe a listening socket for incoming connections,
* which then triggers a read event for the observed stream.
*
* It is recommended that the stream you add is set to non-blocking mode.
*
* If there is an -[observe] call blocking, it will be canceled. The reason for
* this is to prevent blocking even though the new added stream is ready.
*
* \param stream The stream to observe for reading
*/
- (void)addStreamToObserveForReading: (OFStream*)stream;
/**
* Adds a stream to observe for writing.
* \brief Adds a stream to observe for writing.
*
* It is recommended that the stream you add is set to non-blocking mode.
*
* If there is an -[observe] call blocking, it will be canceled. The reason for
* this is to prevent blocking even though the new added stream is ready.
*
* \param stream The stream to observe for writing
*/
- (void)addStreamToObserveForWriting: (OFStream*)stream;
/**
* Removes a stream to observe for reading.
* \brief Removes a stream to observe for reading.
*
* If there is an -[observe] call blocking, it will be canceled. The reason for
* this is to prevent the removed stream from still being observed.
*
* \param stream The stream to remove from observing for reading
*/
- (void)removeStreamToObserveForReading: (OFStream*)stream;
/**
* Removes a stream to observe for writing.
* \brief Removes a stream to observe for writing.
*
* If there is an -[observe] call blocking, it will be canceled. The reason for
* this is to prevent the removed stream from still being observed.
*
* \param stream The stream to remove from observing for writing
*/
- (void)removeStreamToObserveForWriting: (OFStream*)stream;
/**
* Observes all streams and blocks until an event happens on a stream.
* \brief Observes all streams and blocks until an event happens on a stream.
*/
- (void)observe;
/**
* Observes all streams until an event happens on a stream or the timeout is
* reached.
* \brief Observes all streams until an event happens on a stream or the
* timeout is reached.
*
* \param timeout The time to wait for an event, in milliseconds
* \return A boolean whether events occurred during the timeinterval
*/
- (BOOL)observeWithTimeout: (int)timeout;
/// \cond internal
- (BOOL)_processCache;
/// \endcond
@end
@interface OFObject (OFStreamObserverDelegate) <OFStreamObserverDelegate>
@end
|