twyatt

import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.channels.Channel.Factory.CONFLATED
import kotlinx.coroutines.channels.ClosedReceiveChannelException
import kotlinx.coroutines.delay
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking

class SourceClosed(cause: Throwable) : IllegalStateException(cause)

fun main(args: Array<String>) = runBlocking<Unit> {

twyatt

import kotlinx.coroutines.channels.*
import kotlinx.coroutines.channels.Channel.Factory.CONFLATED
import kotlinx.coroutines.delay
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking

fun main(args: Array<String>) = runBlocking<Unit> {
    val channel = Channel<Int>(CONFLATED)

    launch {

twyatt

Demonstrates closing channel 1. Channel 2 continues to be consumable (wrapper is not closed).

(cancelMode = CancelMode.CHANNEL)

main → threads=[Monitor Ctrl-Break, Signal Dispatcher, Finalizer, main @coroutine#1, Reference Handler]
Wrapper[1] → createChannel → <start>
Wrapper[1] → client.observe
Client → observe
Client → observe → thread → handler.onResponse(0)
Wrapper[1] → onResponse → <start>

twyatt

import kotlinx.coroutines.experimental.channels.actor
import kotlinx.coroutines.experimental.channels.consumeEach
import kotlinx.coroutines.experimental.newSingleThreadContext
import kotlinx.coroutines.experimental.runBlocking

val threads: Set<Thread>
    get() = Thread.getAllStackTraces().keys

val threadNames: List<String>
    get() = threads.map { it.name }

twyatt

[user]
	name = Travis Wyatt
	email = <REDACTED>

[alias]
	co = checkout
	br = branch
	st = status
	wip = !git add --verbose --all && git commit --all --verbose --message='wip'
	history = log --all --graph --pretty=format:'%Cred%h%Creset -%C(yellow)%d%Creset %s %Cgreen(%cr) %C(bold blue)<%an>%Creset' --abbrev-commit --date=relative

twyatt

import io.reactivex.Observable
import io.reactivex.Single
import io.reactivex.observers.DisposableObserver
import io.reactivex.schedulers.Schedulers

fun main(args: Array<String>) {
  val list = listOf(3, 2, 1)
  val list2 = listOf(1f, 7f, 8f)

  Observable.fromIterable(list)

twyatt

typealias ColorFunction = (currentTimeMillis: Long) -> Int

class CustomView : View {
    
    val paint = Paint()
    var colorFunction: ColorFunction? = null
    
    override fun onDraw(canvas: Canvas) {
        super.onDraw(canvas)
        

twyatt

=IF(A1>89,"A",IF(A1>79,"B",IF(A1>69,"C",IF(A1>59,"D","F"))))

twyatt

	// parse command line arguments for flags (i.e. help and output filename)
	for (i = 1; i < argc; i++) {
		if (argv[i][0] == '-') { /* flag */
			if (strcmp(argv[i], "-h") == 0 || strcmp(argv[i], "--help") == 0) {
				usage(argv[0]);
				exit(EXIT_SUCCESS);
			}

			if (strcmp(argv[i], "-o") == 0) {
				if (i >= argc - 1) {

twyatt

import javafx.application.Application;
import javafx.event.EventHandler;
import javafx.print.PrinterJob;
import javafx.scene.Scene;
import javafx.scene.input.MouseEvent;
import javafx.scene.layout.Pane;
import javafx.scene.shape.Rectangle;
import javafx.stage.Stage;

public class PrintTest extends Application {