And

Inputs: i1 i2
Outputs: o1

Synchronizes two streams (given by i1 and i2) and emits the logical conjuntion of the values for a given $t_n$.

The synchronization mechanism is inherited from the Join operator. The And operator holds a message buffer on i1 and i2 respectively, it emits a modified version of the synchronized messages from i1 and i2 as the logical conjuntion of its values through o1 right after the synchronization takes place, if no synchronization occurs then an empty message {} is emitted through o1.

$y(t_n)=x_1(t_n) \wedge x_2(t_n)$

Parameters

id: The id of the operator

Usage

TypeScript

import { Program, And } from "@rtbot-dev/rtbot";

const id = "id";

const program = new Program();
program.addOperator(new And(id));

Python

import rtbot as rb

id = "id";

program = rb.Program()
program.addOperator(rb.And(id))

C++

#include "rtbot/And.h"

auto id = "id";

auto op = And<std::uint64_t, double>(id)

YAML

# minimal RtBot program
operators:
  - type: And
    id: "id"

Json

{
  "operators": [
    { "type": "And", "id": "id" }
  ] 
}