carlhoerberg

var amqp = require('amqplib/callback_api');

// if the connection is closed or fails to be established at all, we will reconnect
var amqpConn = null;
function start() {
  amqp.connect(process.env.CLOUDAMQP_URL + "?heartbeat=60", function(err, conn) {
    if (err) {
      console.error("[AMQP]", err.message);
      return setTimeout(start, 1000);
    }

mbalex99

let rx_request = Observable<Value>.create { (observer) -> Disposable in
            let requestReference = Alamofire.request(.POST, url, parameters: payload)
                .responseJSON(completionHandler: { (response) in
                    if let value = response.result.value {
                        observer.onNext(value)
                        observer.onCompleted()
                    }else if let error = response.result.error {
                        observer.onError(error)
                    }
                })

Jerrot

// Based on Swift 1.2, ObjectMapper 0.15, RealmSwift 0.94.1
// Author: Timo Wälisch <[email protected]>

import UIKit
import RealmSwift
import ObjectMapper
import SwiftyJSON

class ArrayTransform<T:RealmSwift.Object where T:Mappable> : TransformType {
    typealias Object = List<T>

rclai

// Thanks @trusktr
var requestSync = Meteor.wrapAsync(function(url, callback) {
  request(url, function(error, response, body) {
    callback(error, {response: response, body: body})
  })
});

var result = requestSync("http://google.com");

console.log(result.response, result.body);

sectore

import React, {DeviceEventEmitter} from 'react-native';
import {Observable} from 'rx-lite'

/**
 * Creates an Observable to listen to any event of DeviceEventEmitter
 * @param type {string} Event type
 */
export default createObservableFromDeviceEventEmitter$ = type => {
  let subscription;
  return Observable.fromEventPattern(

eignatov

# generate OpenSSL CSR here
# https://www.digicert.com/easy-csr/openssl.htm

# to cer

cat COMODORSADomainValidationSecureServerCA.crt COMODORSAAddTrustCA.crt AddTrustExternalCARoot.crt  > yourdomain.com.cer

# to pem

cat yourdomain.com.crt COMODORSADomainValidationSecureServerCA.crt COMODORSAAddTrustCA.crt AddTrustExternalCARoot.crt yourdomain.com.key > yourdomain.com.pem

jarretmoses

RN < 0.50 - watchman watch-del-all && rm -rf $TMPDIR/react-* && rm -rf node_modules/ && npm cache clean && npm install && npm start -- --reset-cache
RN >= 0.50 -  watchman watch-del-all && rm -rf $TMPDIR/react-native-packager-cache-* && rm -rf $TMPDIR/metro-bundler-cache-* && rm -rf node_modules/ && npm cache clean && npm install && npm start -- --reset-cache
RN >= 0.63 - watchman watch-del-all && rm -rf node_modules && npm install && rm -rf /tmp/metro-* && npm run start --reset-cache

npm >= 5 - watchman watch-del-all && rm -rf $TMPDIR/react-* && rm -rf node_modules/ && npm cache verify && npm install && npm start -- --reset-cache

Windows - del %appdata%\Temp\react-native-* & cd android & gradlew clean & cd .. & del node_modules/ & npm cache clean --force & npm install & npm start -- --reset-cache

sibelius

import React from 'react';
import {
  View,
  Text,
} from 'react-native';
import { TextInputMask } from 'react-native-masked-text'

export default function maskedInputTemplate(locals) {
  if (locals.hidden) {
    return null;

mminer

import RxSwift
import SocketIO

extension Reactive where Base: SocketIOClient {

    public func on(_ event: String) -> Observable<[Any]> {
        return Observable.create { observer in
            let id = self.base.on(event) { items, _ in
                observer.onNext(items)
            }

pavsidhu

import React, {Component} from 'react'
import {View, Button} from 'react-native'

import TextField from 'textfield'
import validation from 'validation'
import validate from 'validation_wrapper'

export default class Form extends Component {
  constructor(props) {
    super(props)