make

Un stream est composé d'au moins un flux logique, créé avec make()

Usage

interface org.mddynamics.network.stream.StreamFactory

    public LinkStream make(String name)

@param name: nom du flux logique sous lequel toutes les clauses suivantes s'exécuteront. Le nom logique du flux est affiché dans l'arborescence de l'algorithme du stream

@return retourne une nouvelle instance de flux LinkStream

Exemple de code

la clause make() est utilisée dans la méthode build() de la factory du stream

    @Override
    public void build() throws Exception {
        // Flux logique exposant une api REST de requêtage des données de production
        make("power moniroting api")
            .from("http", "www.mddynamics.fr/app/api", (stream, event) -> {
                return validRequest(event);
            })
              .read("data", "www.mddynamics.fr/app/data..", (stream, event) -> {                       
             ...
        
        // Flux logique de collecte des données de production
        make("power data collect")
            .from("collect", "www.mddynamics.fr/app/data..", (stream, event) -> {
                return validData(event);
            })
             .store("data", "www.mddynamics.fr/app/data..", (stream, event) -> {                       
             ...
    }