ON THIS PAGE
Sockets I/O
Author(s): Francisco Bueno, Jose F. Morales (minor changes, queue version).
This module implements a socket-based message reading loop.
Usage and interface
- Library usage:
:- use_module(library(sockets/sockets_io)). - Exports:
Documentation on exports
PREDICATEserve_socket/3
Usage:serve_socket(Socket,Serve,Handler)
Handles the streams associated to Socket calling Serve on one request of each stream (as Serve(Stream,Unwatch)), and Handler(Stream) if the stream is empty (connection closed). It is expected that Unwatch is unified with yes or no after calls to Serve. If Unwatch=yes then the Stream is removed from the watch list (e.g., useful when the application will perform IO on that stream from a separate thread)
- Call and exit should be compatible with:
(sockets_io:socket/1)Socket is a socket id.
(basic_props:cgoal/1)Serve is a term which represents a goal, i.e., an atom or a structure.
(basic_props:cgoal/1)Handler is a term which represents a goal, i.e., an atom or a structure.
PREDICATEsocket_send_term/2
Usage:socket_send_term(Stream,Term)
Writes Term to Stream in a way that it is safe for a socket connection on Stream.
- Call and exit should be compatible with:
(stream_basic:stream/1)Stream is an open stream.
(basic_props:term/1)Term is any term.
PREDICATEsocket_recv_term/2
No further documentation available for this predicate.
PREDICATEsocket_send_fastrw/2
No further documentation available for this predicate.
PREDICATEsocket_recv_fastrw/2
No further documentation available for this predicate.