Isan-Rivkin

#!/bin/bash

brew install python3

# install asio and tinyxml2 for Fast-RTPS
brew install asio tinyxml2

# install dependencies for robot state publisher
brew install tinyxml eigen pcre poco

Isan-Rivkin

{"nodes":[{"address":"0x32be343b94f860124dc4fee278fdcbd38c102d88","type":"exchange","ether":"31200.395874066955","outTX":1142008,"is_valid_address":true},{"address":"0xfbb1b73c4f0bda4f67dca266ce6ef42
f520fbb98","type":"exchange","ether":"741231.2171651638","outTX":4707609,"is_valid_address":true},{"address":"0x0607B0c8cF73D916b3EF1463bb6fB9f19e9D5D98","type":"user","ether":"1.3511024323593201","outTX":6,"i
s_valid_address":true}],"edges":[{"from":"0x32be343b94f860124dc4fee278fdcbd38c102d88","to":"0xfbb1b73c4f0bda4f67dca266ce6ef42f520fbb98","value":"0.0000000000000000049900000000000004","time":"Invalid date"},{"f
rom":"0x32be343b94f860124dc4fee278fdcbd38c102d88","to":"0xfbb1b73c4f0bda4f67dca266ce6ef42f520fbb98","value":"0.00000000000000007582800001000001","time":"Invalid date"},{"from":"0xfbb1b73c4f0bda4f67dca266ce6ef4
2f520fbb98","to":"0x4fdaebe9eac15eb5bc0170f6a36f19eaed75d8ef","value":"0.000000000000000069","time":"Invalid date"},{"from":"0x32be343b94f860124dc4fee278fdcbd38c102d88","to":"0xfbb1b73c4f0bda4f6

Isan-Rivkin

use std::fs::File;
use std::path::Path;
use parquet::file::reader::{FileReader, SerializedFileReader};
use parquet::record::RowAccessor;

pub fn pq_from_file(){
    let file = File::open(&Path::new("./result.pq")).unwrap();
    let reader = SerializedFileReader::new(file).unwrap();
    let mut iter = reader.get_row_iter(None).unwrap();

Isan-Rivkin

from selenium import webdriver
from selenium.webdriver.chrome.options import Options
from selenium.webdriver.common.action_chains import ActionChains
import time 
from bs4 import BeautifulSoup
import pypdfrom selenium import webdriver
from selenium.webdriver.chrome.options import Options
from selenium.webdriver.common.action_chains import ActionChains
import time 
from bs4 import BeautifulSoup

Isan-Rivkin

use std::sync::Arc;
use zmq;
use tokio;
use futures::{Future, Stream};
use tokio_zmq::{prelude::*, Rep};

use rand::{self,Rng};

use std::{thread, time};
#[derive(Debug)]

Isan-Rivkin

// parallel batch computation with callback in the end
const parallel = require('async/parallel');
// sequential batch computation with callback in the end
const waterfall = require('async/waterfall');

// all the tasks below run at the same time
function computerParallelBatch(){
  parallel([
    cb=>{
      setTimeout(()=>{

Isan-Rivkin

#[derive(PartialEq,Debug,Clone, Copy)]
enum Token{
    Add, // +
    Sub, // _
    Right, // > 
    Left, // <
    Read, // , 
    Write, // . 
    BeginLoop, // [ 
    EndLoop, // ] 

Isan-Rivkin

[package]
name = "state_initial"
version = "0.1.0"
authors = ["Isan-Rivkin <isanrivkin@gmail.com>"]

[dependencies]
json-patch = "0.2.2"
serde_json = "1.0.24"
rmpv="0.4.0"
rmp-serde = "0.13.7"

Isan-Rivkin

package actor_map;

import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.typed.Behavior;

import java.time.Duration;
import java.util.*;

Isan-Rivkin

#[macro_use]
extern crate serde_json;
extern crate json_patch;

use json_patch::{patch, diff, from_value};
use serde_json::from_str;
use json_patch::merge;

fn create_and_patch_document_using_json_patch(){
    let mut doc = json!([