package eliom

You can search for identifiers within the package.

in-package search v0.2.0

Advanced Client/server Web and mobile framework

Install

dune-project

Dependency

ocsigen.org Readme Edit opam file Versions (33)

Authors

D

dev@ocsigen.org

Maintainers

D

dev@ocsigen.org

Sources

10.2.0.tar.gz

md5=089b68d5bac8dfae1116923f6d95b39c

sha512=b4828b57d963d217ca0efd871b1c0b3f8816c7971825eb49d0dc06dbd91004fc659f83f9121d849ab8de47560941d07b2b9c1838b3387e7c1a4d3d6b9058936b

doc/eliom.server/Eliom_bus/index.html

Module `Eliom_bus`Source

Broadcasting facilities between clients and server

Please read the <<a_manual chapter="clientserver-communication" | chapter on communication >> of Eliom's manual before this page to learn how client and server parts communicate.

Sourcetype ('a, 'b) t

The type of bus's carrying values of type 'a. Bus's are values that can be easily shared among clients. Each of these clients along with the server can send a value on the bus. Values can be received by each of the participants as a stream. Note that no effort is put to order message receptions on the different participants.

Source

val create : 
  ?scope:[< Eliom_comet.Channel.comet_scope ] ->
  ?name:string ->
  ?size:int ->
  'a Deriving_Json.t ->
  ('a, 'a) t

create ?scope ?name ?size ?filter t creates a fresh bus. The scope parameter is used to chose the kind of channel on which the bus rely (See Eliom_comet.create for more information). The ?name argument allow one to make bus's persistent over server restart. The size argument behaves like the one on Eliom_comet.Channel.create. If ?filter argument is present, data is filtered through this function before entering the bus. Use this for example if you want to add some information, like IP address, or user id.

Source

val create_filtered : 
  ?scope:[< Eliom_comet.Channel.comet_scope ] ->
  ?name:string ->
  ?size:int ->
  filter:('a -> 'b Lwt.t) ->
  'a Deriving_Json.t ->
  ('a, 'b) t

Same as create, but data is filtered through filter function before entering the bus. Use this for example if you want to add some information, like IP address, or user id.

Sourceval stream : ('a, 'b) t -> 'b Lwt_stream.t

stream b returns the stream of data sent to bus b. Notice you should not use that function multiple times on the same bus, it will return the same stream. If you want to receive multiple times the same data, you should copy the stream with Lwt_stream.clone

Sourceval write : ('a, 'b) t -> 'a -> unit Lwt.t

write b x sends the value x on the bus b. Every participant, including the server, will receive x.