FireZenk

import android.graphics.Canvas
import android.support.v7.widget.RecyclerView
import android.support.v7.widget.helper.ItemTouchHelper
import android.support.v7.widget.helper.ItemTouchHelper.*
import android.view.View

abstract class GenericSwipeCallback(
        private var swipeLeft: SwipeAction? = null,
        private var swipeRight: SwipeAction? = null
) : ItemTouchHelper.Callback() {

FireZenk

//
//  Bot
//  class for performing various twitter actions
//
var Twit = require('../lib/twitter');

var Bot = module.exports = function(config) { 
  this.twit = new Twit(config);
};

FireZenk

import android.content.Intent
import timber.log.Timber

fun dumpIntent(intent: Intent) {
    val bundle = intent.extras
    if (bundle != null) {
        val keys = bundle.keySet()
        val it = keys.iterator()
        Timber.e("------->>> Dumping Intent start")
        while (it.hasNext()) {

FireZenk

import java.io.ByteArrayOutputStream
import java.io.File
import java.nio.charset.StandardCharsets.UTF_8
import java.util.zip.GZIPInputStream
import java.util.zip.GZIPOutputStream

fun String.gzip(): ByteArray {
    val bos = ByteArrayOutputStream()
    GZIPOutputStream(bos).bufferedWriter(UTF_8).use { it.write(this) }
    return bos.toByteArray()

FireZenk

import android.text.Spanned
import android.text.style.ImageSpan
import android.graphics.drawable.ColorDrawable
import android.text.SpannableString
import android.text.SpannableStringBuilder
import android.widget.TextView
import java.util.concurrent.atomic.AtomicBoolean

fun TextView.justify() {

FireZenk

import java.util.concurrent.TimeUnit;

import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.WebSocket;
import okhttp3.WebSocketListener;
import rx.Observable;

public class RxSocketConnection extends WebSocketListener {

FireZenk

import android.support.annotation.IdRes
import android.support.v7.widget.SearchView
import android.support.v7.widget.Toolbar
import android.view.MenuItem


@DslMarker
annotation class ToolbarSearchDsl

@ToolbarSearchDsl

FireZenk

object WebSocket : WebSocketListener() {

    private lateinit var broadcaster: FlowableEmitter<String>
    private lateinit var disposable: Disposable
    private lateinit var webSocket: WebSocket
    private val flowable = Flowable.create(FlowableOnSubscribe<String> { emitter -> broadcaster = emitter }, BackpressureStrategy.BUFFER)

    fun subscribe(): Flowable<String> {
        val client = OkHttpClient.Builder()
                .readTimeout(0, TimeUnit.MILLISECONDS)

FireZenk

object SignalrSocket {

    private lateinit var broadcaster: FlowableEmitter<String>
    private lateinit var disposable: Disposable
    private val flowable = Flowable.create(FlowableOnSubscribe<String> { emitter -> broadcaster = emitter }, BackpressureStrategy.BUFFER)

    private lateinit var mHubConnection: HubConnection
    private lateinit var mHubProxy: HubProxy

    @Throws(InterruptedException::class, ExecutionException::class)

FireZenk

<my.package.MyCustomView
          android:id="@+id/my_view"
          android:layout_width="match_parent"
          android:layout_height="match_parent" />