clemp6r

package com.github.clemp6r.azuregradle

import org.gradle.api.DefaultTask

import com.microsoft.azure.storage.*;
import com.microsoft.azure.storage.blob.*
import org.gradle.api.tasks.TaskAction;

class AzureStorageDeployTask extends DefaultTask {

clemp6r

import com.github.clemp6r.futuroid.Async;
import com.github.clemp6r.futuroid.Future;

import java.util.concurrent.Callable;

import rx.Observable;
import rx.subjects.PublishSubject;

/**
 * Helper for integrating Futuroid with Rx.

clemp6r

package com.wizbii.wizbiiandroid.services

import rx.Observable
import rx.subjects.PublishSubject

/**
 * POC of a reactive data store.
 */
abstract class ReactiveStore<T> {

clemp6r

// inferred type is Sequence<Int>
val fibonacci = buildSequence {
    yield(1)
    var cur = 1
    var next = 1
    while (true) {
        yield(next)
        val tmp = cur + next
        cur = next
        next = tmp