Srepfler Srdan schrepfler

David's programming examples knowledge base

Generated by code-examples-manager release 2.4.7-SNAPSHOT
606 published examples

akka-pekko

akka-actors-hello-world.sc : Simple akka hello world example
akka-capitalize-and-print.sc : dump capitalized string coming from stdin using streams
akka-http-client-json-stream.sc : Fully asynchronous http client call with json streamed response using akka-http will work in all cases, even with chunked responses !
akka-http-client-json-with-proxy.sc : Fully asynchronous http client call with json response using akka-http will work in all cases, even with chunked responses, this example add automatic http proxy support.
[akka-http-client-json.sc](https:/

Variants: the ultimate frontier

Most data serialization formats, like JSON, YAML, and EDN, feature a similar set of basic building blocks, namely:

Some primitive values, like numbers, strings, and booleans;
Key-value pairs, also known as maps, dictionaries, or objects;
Sequences, usually in the form of lists or arrays, and sometimes also sets.

I completely agree with the fact that those are basic building blocks for data inside any information system. However, as a Haskeller I always miss one additional part of my toolbox: variants. Variants are essentially tagged values which contain further values inside.

Photon demo: database branching (time travel)

This demo uses DataScript's API for speculative transactions, not sure if can be done with sql read transactions.
DataScript is on the server; code is network-transparent.
100 LOC for everything (table, query, popover, css, page)

20220910.branched.popover.staging.area.2.mp4

Aliases for Apache Pulsar CLI tools with JWT auth

Usage

Add the pulsar-cli-aliases.shfile content to your ~/.bashrc or ~/.zshrc.
Fill pulsar_jwt, pulsar_url, pulsar_admin_url with your values.
Then use short commands like pa topics stats public/default/topic-a instead of

pulsar-admin \

	package swar.subword;

	public class SWAR_Intro_NoComments
	{
	public static void main ( String[] args )
	{
	int x = 12345678;
	int y = 9012345;

	long xyCompound = as2x32BitCompound ( x, y );

	def switchMap[F[_]: Async, A, B](f: A => Stream[F, B]): Pipe[F, A, B] = {
	def go(
	outer: ScopedFuture[F, Pull[F, Nothing, (NonEmptyChunk[A], Handle[F, A])]],
	inner: ScopedFuture[F, Pull[F, Nothing, (NonEmptyChunk[B], Handle[F, B])]]
	): Pull[F, B, Nothing] = {
	(outer race inner).pull.flatMap {
	case Left(outer) =>
	outer.optional.flatMap {
	case None =>
	inner.pull.flatMap(identity).flatMap { case (hd, tl) => Pull.output(hd) >> tl.echo }

	/*
	Copyright 2021 Jakub Kozłowski

	Licensed under the Apache License, Version 2.0 (the "License");
	you may not use this file except in compliance with the License.
	You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software

	// Oto Brglez - <[email protected]> - May 2021
	package com.pinkstack.gen4

	import cats.effect.implicits._
	import cats.effect.{ExitCode, IO, IOApp}
	import cats.implicits._
	import com.pinkstack.gen1.CoinMarketCap.Implicits._
	import com.pinkstack.gen1.CoinMarketCap._
	import sttp.client3._
	import sttp.client3.circe._

	const std = @import("std");

	pub fn build(b: *std.Build) void {
	// Standard target options allows the person running `zig build` to choose
	// what target to build for. Here we do not override the defaults, which
	// means any target is allowed, and the default is native. Other options
	// for restricting supported target set are available.
	const target = b.standardTargetOptions(.{});

	// Standard optimization options allow the person running `zig build` to select

	default['sshd']['sshd_config']['AuthenticationMethods'] = 'publickey,keyboard-interactive:pam'
	default['sshd']['sshd_config']['ChallengeResponseAuthentication'] = 'yes'
	default['sshd']['sshd_config']['PasswordAuthentication'] = 'no'