uint64_t num_peers,
const struct GNUNET_PeerIdentity *peers);
-/**
- * Callback called when view was updated
- *
- * @param num_peers the number of peers returned
- * @param peers array with num_peers PeerIDs
- */
-typedef void (* GNUNET_RPS_ViewUpdateCB) (void *cls,
- uint64_t num_peers,
- const struct GNUNET_PeerIdentity *peers);
-
-/**
- * Callback called when a peer from the biased stream was received
- *
- * @param peer The received peer
- */
-typedef void (* GNUNET_RPS_StreamInputCB) (void *cls,
- uint64_t num_peers,
- const struct GNUNET_PeerIdentity *peer);
/**
* Connect to the rps service
void
GNUNET_RPS_view_request (struct GNUNET_RPS_Handle *rps_handle,
uint32_t num_updates,
- GNUNET_RPS_ViewUpdateCB view_update_cb,
+ GNUNET_RPS_NotifyReadyCB view_update_cb,
void *cls);
* @param cls a closure that will be given to the callback
* @param ready_cb the callback called when the peers are available
*/
-void
+struct GNUNET_RPS_StreamRequestHandle *
GNUNET_RPS_stream_request (struct GNUNET_RPS_Handle *rps_handle,
uint32_t num_updates,
- GNUNET_RPS_StreamInputCB stream_input_cb,
+ GNUNET_RPS_NotifyReadyCB stream_input_cb,
void *cls);