dluc

// Test.java

import com.microsoft.azure.iot.service.sdk.DeliveryAcknowledgement;
import com.microsoft.azure.iot.service.sdk.IotHubServiceClientProtocol;
import com.microsoft.azure.iot.service.sdk.Message;
import com.microsoft.azure.iot.service.sdk.ServiceClient;

import java.nio.charset.StandardCharsets;
import java.text.DateFormat;
import java.text.SimpleDateFormat;

dluc

package com.microsoft.azure.iothub;

import com.microsoft.azure.iot.service.sdk.FeedbackBatch;
import com.microsoft.azure.iot.service.sdk.FeedbackReceiver;
import com.microsoft.azure.iot.service.sdk.IotHubServiceClientProtocol;
import com.microsoft.azure.iot.service.sdk.ServiceClient;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

dluc

package com.microsoft.azure.iothub;

import com.microsoft.azure.iot.service.sdk.FeedbackReceiver;
import com.microsoft.azure.iot.service.sdk.IotHubServiceClientProtocol;
import com.microsoft.azure.iot.service.sdk.ServiceClient;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

dluc

/*
 * Copyright (c) Microsoft. All rights reserved.
 * Licensed under the MIT license. See LICENSE file in the project root for full license information.
 */

import com.microsoft.azure.iot.service.sdk.*;

import java.io.IOException;
import java.net.URISyntaxException;
import java.util.Date;

dluc

package com.company;

import com.microsoft.azure.iot.service.sdk.*;

import java.io.IOException;
import java.net.URISyntaxException;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CompletableFuture;

dluc

case class IoTHub() {
  
  def source(): Source[MessageFromDevice, NotUsed] = /* ... */
  
  def sink[A]()(implicit typedSink: TypedSink[A]): Sink[A, Future[Done]] = typedSink.definition
}

trait TypedSink[A] {
  def definition: Sink[A, Future[Done]]
}

dluc

Keybase proof

I hereby claim:

• I am dluc on github.
• I am devis (https://keybase.io/devis) on keybase.
• I have a public key ASAqKf0qDP-UL3yWsfNW557yWMjZf3JsaAhsn2KkmCTYzgo

To claim this, I am signing this object:

dluc

1. brew install gnupg21, pinentry-mac (this includes gpg-agent and pinentry)

2. Generate a key: $ gpg --gen-key

3. Take the defaults. Whatevs

4. Tell gpg-agent to use pinentry-mac:

   $ vim ~/.gnupg/gpg-agent.conf 
   

dluc

# In order for gpg to find gpg-agent, gpg-agent must be running, and there must be an env
# variable pointing GPG to the gpg-agent socket. This little script, which must be sourced
# in your shell's init script (ie, .bash_profile, .zshrc, whatever), will either start
# gpg-agent or set up the GPG_AGENT_INFO variable if it's already running.

# Add the following to your shell init to set up gpg-agent automatically for every shell
if [ -f ~/.gnupg/.gpg-agent-info ] && [ -n "$(pgrep gpg-agent)" ]; then
    source ~/.gnupg/.gpg-agent-info
    export GPG_AGENT_INFO
else