Frank Lyaruu flyaruu

flyaruu / gist:6142772d5324e7fec40546b5d44c56a5

Created July 27, 2025 16:46

peugeot_gears_can.csv

	Time Stamp,ID,Extended,Dir,Bus,LEN,D1,D2,D3,D4,D5,D6,D7,D8
	0,00000305,false,Rx,0,7,EB,7F,00,07,39,00,C0,00,
	0,0000030D,false,Rx,0,8,00,00,00,00,00,00,00,00,
	0,0000034D,false,Rx,0,8,00,23,FA,FA,00,04,00,FF,
	0,0000038D,false,Rx,0,7,00,00,00,00,AF,AA,37,00,
	0,000003CD,false,Rx,0,8,FF,FB,00,00,00,22,90,FE,
	0,00000208,false,Rx,0,8,00,00,32,00,0C,32,32,32,
	0,00000348,false,Rx,0,8,00,32,34,32,C1,01,44,00,
	0,000002F5,false,Rx,0,7,BA,00,00,FF,F9,00,00,00,
	0,00000305,false,Rx,0,7,EB,7F,00,07,0A,00,C0,00,

flyaruu / readme.md

Created May 21, 2025 12:35

Thanks for coming, CodeMotion Madrid!

Links

Hi Code Motion Madrid, thanks for the interest!

If you feel like it, connect to me on LinkedIn:

Or follow me on GitHub

flyaruu / Cargo.toml

Created July 7, 2024 11:12

MQTT embedded-tls issue

	[package]
	name = "test-mqtt-std"
	version = "0.1.0"
	edition = "2021"

	[dependencies]
	embedded-tls = { git="https://github.com/drogue-iot/embedded-tls"}
	rand = "0.8.5"
	tokio = { version = "1.38.0", features = ["macros", "net", "rt", "rt-multi-thread", "tokio-macros", "time"] }
	embedded-io-adapters = { version = "0.6", features = ["tokio-1"] }

flyaruu / pubsub.rs

Last active November 26, 2023 22:48

Expanded example

	use std::{
	net::{Ipv4Addr, SocketAddr},
	time::Duration, str::from_utf8,
	};

	use embedded_io_adapters::tokio_1::FromTokio;
	use rust_mqtt::{
	client::{client::MqttClient, client_config::ClientConfig},
	packet::v5::reason_codes::ReasonCode,
	utils::rng_generator::CountingRng,

flyaruu / TestDeletePointCut.java

Created December 1, 2021 12:18

	package hapi;

	import ca.uhn.fhir.context.FhirContext;
	import ca.uhn.fhir.interceptor.api.Hook;
	import ca.uhn.fhir.interceptor.api.Pointcut;
	import ca.uhn.fhir.rest.api.DeleteCascadeModeEnum;
	import ca.uhn.fhir.rest.api.MethodOutcome;
	import ca.uhn.fhir.rest.api.server.RequestDetails;
	import ca.uhn.fhir.rest.client.api.IGenericClient;
	import ca.uhn.fhir.rest.client.api.ServerValidationModeEnum;

flyaruu / TestIssue.java

Last active May 9, 2019 13:35

	import java.time.Duration;

	import org.junit.Test;

	import io.r2dbc.pool.ConnectionPool;
	import io.r2dbc.pool.ConnectionPoolConfiguration;
	import io.r2dbc.postgresql.PostgresqlConnectionConfiguration;
	import io.r2dbc.postgresql.PostgresqlConnectionFactory;
	import io.r2dbc.spi.Connection;
	import reactor.core.publisher.Flux;

flyaruu / BeforeNPEWithDebug

Created June 20, 2018 12:24

	[lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason-43871f6a-e485-4617-85a4-ce1709608a86-StreamThread-1] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason-43871f6a-e485-4617-85a4-ce1709608a86-StreamThread-1-consumer, groupId=lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason] Committed offset 1306 for partition KNBSB-develop-sportlinkkernel-COMPETITIONTYPEATTRIBUTE-0
	[lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason-43871f6a-e485-4617-85a4-ce1709608a86-StreamThread-1] DEBUG org.apache.kafka.streams.processor.internals.AssignedStreamsTasks - stream-thread [lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason-43871f6a-e485-4617-85a4-ce1709608a86-StreamThread-1] Committed active task 4_0 per user request in
	[lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason-43871f6a-e485-4617-85a4-ce1709608a86-StreamThread-1] DEBUG org.apache.kafka.streams.processor.

flyaruu / gist:39fba78aec562ae5d6f11d3add6a0881

Created June 20, 2018 11:48

Topology description

	Topologies:
	Sub-topology: 0
	Source: sportlinkkernel-ORGANIZATIONCOMMUNICATION_src (topics: [KNBSB-develop-sportlinkkernel-ORGANIZATIONCOMMUNICATION])
	--> sportlinkkernel-ORGANIZATIONCOMMUNICATION_transform
	Processor: sportlinkkernel-ORGANIZATIONCOMMUNICATION_transform (stores: [])
	--> sportlinkkernel-ORGANIZATIONCOMMUNICATION
	<-- sportlinkkernel-ORGANIZATIONCOMMUNICATION_src
	Source: .FACILITYORG_src (topics: [KNBSB-develop-generation-190620-lowlevel-FACILITYORG])
	--> .FACILITYORG_transform
	Processor: sportlinkkernel-ORGANIZATIONCOMMUNICATION (stores: [sportlinkkernel-ORGANIZATIONCOMMUNICATION])

flyaruu / OneToManyGroupedProcessor.java

Created June 18, 2018 16:02

One-to-many grouped

	package com.dexels.kafka.streams.remotejoin.ranged;

	import java.util.ArrayList;
	import java.util.List;
	import java.util.Optional;
	import java.util.function.BiFunction;

	import org.apache.kafka.streams.KeyValue;
	import org.apache.kafka.streams.kstream.Predicate;
	import org.apache.kafka.streams.processor.AbstractProcessor;