Horusiath’s gists

Horusiath / Interface implementation.md

Last active December 4, 2015 13:47

FSharp

type IReaderWriter =
  abstract member Read : unit -> unit
  abstract member Write : unit -> unit
  
type IReader =
  abstract member Read : unit -> unit

type SomeClass1(x: int, y: float) =

Horusiath / persistent test case.cs

Last active December 9, 2015 21:05

	public sealed class GetState { }
	public sealed class Increment { }

	public sealed class Changed { }

	public class TestCaseActor : UntypedPersistentActor
	{
	private int state = 0;
	public override string PersistenceId { get; } = "yolo";

Horusiath / EnumerableActorRef.cs

Last active December 15, 2015 16:51

This is example of returning responses from actor refs in form of the enumerable.

	public static class EnumerablePatterns
	{
	public static IEnumerable<T> Query<T>(this ICanTell self, object message = null)
	{
	var provider = ResolveProvider(self);
	if (provider == null)
	throw new NotSupportedException("Unable to resolve the target Provider");

	var enumerable = new BlockingCollection<T>();
	var path = provider.TempPath();

Horusiath / Sample.fs

Last active December 30, 2015 13:54

Akka.Persistence.FSharp aggregate/view cooperation

	open System
	open Akka
	open Akka.Actor
	open Akka.FSharp
	open Akka.Persistence.FSharp

	let system = System.create "persistence-sys" <\| Configuration.parse """
	akka {
	persistence {
	journal {

Horusiath / Example.cs

Created February 27, 2016 07:37

Akka.NET layered hierarchy with custom supervisor strategy

	public class CustomException : Exception { }
	public class Boom { }
	public class Grandpa : ReceiveActor
	{
	public Grandpa()
	{
	var parent = Context.ActorOf(Props.Create<Parent>(), "parent");
	ReceiveAny(x => parent.Forward(x));
	}

Horusiath / graphql.fs

Created April 15, 2016 17:09

New API example


	/// These are all of the possible kinds of types
	type GraphQLType =
	interface
	end

	/// These types may be used as input types for arguments and directives
	and InputType<'Inner> =
	interface
	end

Horusiath / Akkling-parent-child-test.fs

Last active November 3, 2020 03:38

	// wrapper function over TestKit.ActorOfAsTestActorRef
	let spawnAsTestRef (tck:Tck) (props: Props<'T>) : IActorRef<'T> =
	typed (tck.ActorOfAsTestActorRef<FunActor<'T>>(props.ToProps(), tck.TestActor) :> IActorRef)

	[<Fact>]
	let ``Parent should create child`` () = testDefault <\| fun tck ->
	// child actor definition
	let child (ctx: Actor<_>) msg = ctx.Sender() <! "hello" \|> ignored
	// parent actor defintion
	let rec parent (ctx: Actor<_>) =

Horusiath / Akka.FSharp.TestKit.fs

Created May 29, 2016 19:58

	open System
	open Akka.Actor
	open Akka.FSharp
	open Akka.TestKit
	open Akka.TestKit.Xunit2

	type Tck = TestKit

	/// <summary>
	/// Runs a test case function in context of TestKit aware actor system.

Horusiath / zipkin error

Created May 31, 2016 10:20

	org.jboss.netty.handler.codec.frame.TooLongFrameException: Maximum frame size of 67108864 exceeded
	at com.facebook.nifty.codec.DefaultThriftFrameDecoder.tryDecodeFramedMessage(DefaultThriftFrameDecoder.java:102) [nifty-core-0.18.0.jar!/:nifty-parent-0.18.0]
	at com.facebook.nifty.codec.DefaultThriftFrameDecoder.decode(DefaultThriftFrameDecoder.java:68) [nifty-core-0.18.0.jar!/:nifty-parent-0.18.0]
	at com.facebook.nifty.codec.DefaultThriftFrameDecoder.decode(DefaultThriftFrameDecoder.java:33) [nifty-core-0.18.0.jar!/:nifty-parent-0.18.0]
	at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:425) [netty-3.10.5.Final.jar!/:na]
	at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303) [netty-3.10.5.Final.jar!/:na]
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) [netty-3.10.5.Final.jar!/:na]
	at com.facebook.nifty.codec.DefaultThriftFrameCode

Horusiath / zipkin http error

Created June 1, 2016 07:02

	2016-06-01 09:00:19.722 ERROR 14028 --- [ thrift-io-0] c.f.nifty.core.NiftyExceptionLogger : Exception triggered on channel connected to /0:0:0:0:0:0:0:1:33153

	org.jboss.netty.handler.codec.frame.TooLongFrameException: Maximum frame size of 67108864 exceeded
	at com.facebook.nifty.codec.DefaultThriftFrameDecoder.tryDecodeFramedMessage(DefaultThriftFrameDecoder.java:102) [nifty-core-0.18.0.jar!/:nifty-parent-0.18.0]
	at com.facebook.nifty.codec.DefaultThriftFrameDecoder.decode(DefaultThriftFrameDecoder.java:68) [nifty-core-0.18.0.jar!/:nifty-parent-0.18.0]
	at com.facebook.nifty.codec.DefaultThriftFrameDecoder.decode(DefaultThriftFrameDecoder.java:33) [nifty-core-0.18.0.jar!/:nifty-parent-0.18.0]
	at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:425) [netty-3.10.5.Final.jar!/:na]
	at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303) [netty-3.10.5.Final.jar!/:na]
	at org.jboss.netty.channel.S

Bartosz Sypytkowski Horusiath

FSharp