diff options
Diffstat (limited to 'src/include/gnunet_stream_lib.h')
-rw-r--r-- | src/include/gnunet_stream_lib.h | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/src/include/gnunet_stream_lib.h b/src/include/gnunet_stream_lib.h index 056695ba3..ece60c033 100644 --- a/src/include/gnunet_stream_lib.h +++ b/src/include/gnunet_stream_lib.h | |||
@@ -395,6 +395,21 @@ void | |||
395 | GNUNET_STREAM_read_cancel (struct GNUNET_STREAM_ReadHandle *rh); | 395 | GNUNET_STREAM_read_cancel (struct GNUNET_STREAM_ReadHandle *rh); |
396 | 396 | ||
397 | 397 | ||
398 | /** | ||
399 | * Create a message queue for a stream socket. | ||
400 | * | ||
401 | * @param socket the socket to read/write in the message queue | ||
402 | * @param msg_handlers message handler array | ||
403 | * @param error_handler callback for errors | ||
404 | * @return the message queue for the socket | ||
405 | */ | ||
406 | struct GNUNET_MQ_MessageQueue * | ||
407 | GNUNET_STREAM_mq_create (struct GNUNET_STREAM_Socket *socket, | ||
408 | const struct GNUNET_MQ_Handler *msg_handlers, | ||
409 | GNUNET_MQ_ErrorHandler error_handler, | ||
410 | void *cls); | ||
411 | |||
412 | |||
398 | #if 0 | 413 | #if 0 |
399 | { | 414 | { |
400 | #endif | 415 | #endif |